Я пытался увидеть поведение потребителя kafka в случае сбоя обработки сообщения, поэтому я сгенерировал исключение runtimexception, если ключ сообщения имеет какое-либо значение.Что я заметил, так это то, что мое потребительское приложение kafka просто перестает обрабатывать здесь любое сообщение.Я понимаю, что Кафка поддерживает порядок, но таким образом приложение никогда не сможет возобновить.
Можем ли мы поместить такое сообщение в тему кафки с ошибкой и двигаться дальше.
Не могли бы вы помочьмне с фрагментом кода, как я могу изящно обрабатывать исключения в Кафке.