卡夫卡确认和卡夫卡消费者commitSync ()有什么区别?
两者都用于手工抵销管理,希望两者同步工作。
请协助
发布于 2020-01-23 01:07:08
当使用spring-kafka时,Acknowledgment
是用于提交偏移量的详细消费者API的抽象。
当您调用acknowledgement.acknowledge()
时,操作取决于配置。使用AckMode.MANUAL
时,提交将排队等待使用者稍后处理;使用MANUAL_IMMEDIATE
时,会立即调用commitSync()
(默认或异步,具体取决于配置)。
https://stackoverflow.com/questions/59864610
复制相似问题