Pra*_*ddy 6 java spring apache-kafka spring-kafka
关于Kafka中的确认模式,以下是我找到的2个文档:
\n从Reference1来看,offset是在消息处理完之后commit\xc2\xa0,即Consumer端的Listener是否顺利返回,没有抛出异常。
\n从参考文献2来看,偏移量是在消息传递给监听器之后提交的,即即使Consumer端的监听器抛出异常,偏移量也已经被提交了。
\n在本地测试后,我觉得该行为与参考文献 1 一致。
\n @KafkaListener(topics = "topicA", groupId = "gid")\n @SendTo\n public Message<Foo> listen(Bar msg)\n {\n //some work\n }\n
Run Code Online (Sandbox Code Playgroud)\n
归档时间: |
|
查看次数: |
894 次 |
最近记录: |