当前位置: 动力学知识库 > 问答 > 编程问答 >

Kafka consumer api in java has to fetch message based on offset

问题描述:

We have a requirement that the consumer should be able to go back to any point of message stream and reprocess the message.

It looks like to set an offset in High level consumer as it needs setting offset in the zookeeper and re-start of consumer is needed.

Simple consumer supports this ,but need to handle broker leader election ,broker leader failure etc.

The new consumer api provide this ,but it looks like this is still in beta.

So we might have to select simple consumer. Any know issues with simple consumers

分享给朋友:
您可能感兴趣的文章:
随机阅读: