I have an odd situation where I have ConsumeKafkaRecord and ConsumeKafka
pulling from the same topic under different consumer groups, but only the
latter will pull new events. I ran into a situation where the reader didn't
like the Avro data being pulled from the queue and so I created new topics
and configured both processors to use the new ones. However, only the
non-record version of the processor will read.

Anyone got suggestions on how to debug this? I'm reasonably familiar with
Kafka, but can't figure out why ConsumeKafka and the console consumer can
read the topic, but ConsumeKafkaRecord is acting like there's nothing there
at all.

Thanks,

Mike

Reply via email to