Spring kafka потребитель перестает получать сообщения

Question

У меня пружинный микросервис с использованием кафки.

Вот свойства конфигурации потребителя 5:

BOOTSTRAP_SERVERS_CONFIG -> <ip>:9092
KEY_DESERIALIZER_CLASS_CONFIG -> StringDeserializer.class
VALUE_DESERIALIZER_CLASS_CONFIG -> StringDeserializer.class
GROUP_ID_CONFIG -> "Group1"
MAX_POLL_INTERVAL_MS_CONFIG -> Integer.INT_MAX

Было замечено, что при перезапуске микросервиса потребитель kafka прекращает прием сообщений.Пожалуйста, помогите мне в этом.

Answer 1

Я думаю, что ваш max.poll.interval.ms является проблемой.Это установлено на 24 дня!Это представляет время, которое дается потребителю для обработки сообщения.Брокер будет висеть так долго, когда поток обработки умирает!Попробуйте установить для него меньшее значение, чем Integer.INT_MAX, например, 30 секунд, 30000 мс.