Java Kafka Переработка ⇐ JAVA

[Anonymous]

Давайте подумаем, что у вас есть потребитель Java, который слушает тему Kafka. /> Я хочу, чтобы он обработал 80 сообщений, а затем обновляется смещение, ошибки и потребление туда, где вы ушли. < /p>
Но как? Также это хорошее решение?

Подробнее здесь: https://stackoverflow.com/questions/796 ... processing