Потребитель Kafka через некоторое время перестает потреблять с аутентификацией Kerberos - PullRequest
0 голосов
/ 07 июня 2018

Мое приложение java-spring успешно получало сообщения от kafka0.9.0.0.но я перешел на kafka0.10.2.0, который там с аутентификацией Kerberos.Итак, на этом новом kafka0.10, когда я запускаю свое потребительское приложение, оно устанавливает аутентификацию kerberos и хорошо потребляет.Но через некоторое время (неопределенное время, иногда 6 часов, 20 часов, 80 часов) он перестанет потреблять сообщения.Как только я перезапущу приложение, оно будет обрабатывать все неиспользуемые сообщения, потреблять их некоторое время и снова останавливаться.Я не понимаю этот странный сценарий потребителя / Кафки / Kerberos.Может ли кто-нибудь помочь мне с тем, как мое приложение может постоянно потреблять?Заранее спасибо.

...