首页 > TAG信息列表 > commitOffset

kafka如何手动异步提交offset

转:https://blog.csdn.net/CREATE_17/article/details/108722808 kafka手动异步提交 offset 的步骤大概分为以下几步,如下图所示:     1、配置手动提交 enable.auto.commit 修改为 false 。 2、订阅 topic consumer.subscribe(Arrays.asList("topic name")); 3、获取 topic 各分