Как мне создать собственный потребительский перехватчик kafka для перехвата одной записи за раз? - PullRequest
Новая
       16

Как мне создать собственный потребительский перехватчик kafka для перехвата одной записи за раз?

0 голосов
/ 11 июня 2019

Я пытаюсь добавить пользовательский перехватчик, используя org.apache.kafka.clients.consumer.ConsumerInterceptor.

Проблема, с которой я столкнулся, заключается в том, что onConsume() метод принимает ConsumerRecords<String, Object> записей, но я ищу перехват только одной записи за раз вместо набора записей.

Как мне это сделать? Пожалуйста, предложите

1 Ответ

0 голосов
/ 20 июня 2019

Мне удалось добиться, реализовав интерфейс 'RecordInterceptor' из 'spring-kafka-2.7.7-RELEASE' без изменения каких-либо настроек на kafka.

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

https://github.com/spring-projects/spring-kafka/issues/1118

...