У нас есть микросервисы загрузки Spring, использующие библиотеку Spring Kafka для публикации sh в темах kafka. Сервис развернут на кластере Kube. Недавно мы заметили, что использование памяти контейнером продолжает расти. Мы должны перезапускать контейнеры один раз в день, чтобы избежать проблем с памятью в кластере.
Анализ дампа кучи, выявил основной подозреваемый
"" org. apache .kafka. clients.producer.internals.RecordAccumulator, "загруженный" org.springframework.boot.loader.LaunchedURLClassLoader @
- Микросервис публикует почти 6 тем (используется kafkaTemplate.send)
- Недавно мы увеличили разделы по всем темам? Может ли это вызвать проблему?
- Можно ли уменьшить размер партии для помощи производителя?
Пожалуйста, помогите.