Kafka入门三:几种消费方式

1.消费位移确认     Kafka消费者消费位移确认有自动提交与手动提交两种策略。在建立KafkaConsumer对象时,经过参数enable.auto.commit设定,true表示自动提交(默认)。自动提交策略由消费者协调器(ConsumerCoordinator)每隔${auto.commit.interval.ms}毫秒执行一次偏移量的提交。手动提交须要由客户端本身控制偏移量的提交。ja
相关文章
相关标签/搜索