Получать ошибочные сообщения с KafkaListener - PullRequest
0 голосов
/ 13 января 2019

Я использую последнюю версию spring-kafka и использую @KafkaListener. Я использую BatchListener. В методе, который прослушивает список сообщений, я хочу вызвать подтверждение, только если пакет записей обработан. Но Spring Framework не отправляет эти сообщения снова, пока я не перезапущу приложение. Поэтому я использовал методы stop () и start () в KafkaListenerEndpointRegistry, если записи не были обработаны, но я считаю, что это не очень хороший способ решения проблемы. Есть ли лучший способ справиться с этим.

1 Ответ

0 голосов
/ 13 января 2019

См. документацию для SeekToCurrentBatchErrorHandler.

SeekToCurrentBatchErrorHandler ищет каждый раздел для первой записи в каждом разделе в пакете, чтобы воспроизвести весь пакет. Этот обработчик ошибок не поддерживает восстановление, потому что платформа не может знать, какое сообщение в пакете дает сбой.

...