如何读取来自kafka的已经提交的消息
How to read the messages from kafka which are already committed
我对kafka有需求,想从kafka读取已经提交的消息而不是所有消息
使用 spring-kafka,实现 ConsumerSeekAware
并且您可以在启动期间寻找您喜欢的任何偏移量。
我对kafka有需求,想从kafka读取已经提交的消息而不是所有消息
使用 spring-kafka,实现 ConsumerSeekAware
并且您可以在启动期间寻找您喜欢的任何偏移量。