We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
hi dennis broker中,updateConsumerOffsets=false
我在consumer设置ConsumerConfig.setConsumeFromMaxOffset 然后启动consumer后,再关闭此consumer
关闭consumer后,product一条信息
此时再设置ConsumerConfig.setConsumeFromMaxOffset后启动consumer,会收到刚才发的那条信息
感觉这个setConsumeFromMaxOffset没起作用
不太确定这是否是setConsumeFromMaxOffset的一个bug
The text was updated successfully, but these errors were encountered:
setConsumeFromMaxOffset只对从未消费过的group生效 因为你前面启动过一次,zookeeper上已经保存了上次的offset 不会取最大了
这个setConsumeFromMaxOffset选项,最主要是给新加入的分组的,防止新加入的分组收到很多老消息
Sorry, something went wrong.
No branches or pull requests
hi dennis
broker中,updateConsumerOffsets=false
我在consumer设置ConsumerConfig.setConsumeFromMaxOffset
然后启动consumer后,再关闭此consumer
关闭consumer后,product一条信息
此时再设置ConsumerConfig.setConsumeFromMaxOffset后启动consumer,会收到刚才发的那条信息
感觉这个setConsumeFromMaxOffset没起作用
不太确定这是否是setConsumeFromMaxOffset的一个bug
The text was updated successfully, but these errors were encountered: