CODEWITHSUNDEEP
apache-kafkakafka-consumer-api
Nidhin jose
Nidhin jose

Reputation: 60

Filter messages using native apache Kafka consumers api before poll

Is there an option to filter messages using native apache Kafka consumers before poll?

RecordFilterStrategy -could see option in spring, but looking for something in native apache kafka consumer api, and dont have an option to produce messages to two different topics.

Upvotes: 0

Views: 109

Answers (1)

OneCricketeer
OneCricketeer

Reputation: 191743

poll returns an iterable collection of records. There's no other way to get the records, and therefore, you cannot filter on record content beforehand (neither does Spring)

Upvotes: 1

Related Questions