#apache-kafka #kafka-consumer-api #apache-kafka-streams
Вопрос:
Я пытаюсь протестировать свой код для обработки некоторых сценариев ошибок. Эта часть кода запускается, когда приходит сообщение по теме.
Я хочу проверить код, когда сообщение так и не придет. У меня есть кое-какая фоновая работа, которая повторяется снова.
Есть ли в любом случае, в котором я останавливаю потребителя, пока не захочу. У меня есть доступ к cli кафки на моем компьютере. Я предпочитаю способ ввода команды для блокировки потребителя.
.
Комментарии:
1. Как вы потребляете сообщения, напрямую или через группу потребителей?