Kafka的assign和subscribe订阅模式和手动提交偏移量

1、前言: 使用Apache Kafka消费者组时,有一个为消费者分配对应分区partition的过程,咱们可使用“自动”subscribe和“手动”assign的方式。html KafkaConsumer.subscribe():为consumer自动分配partition,有内部算法保证topic-partition以最优的方式均匀分配给同group下的不一样consumer。 KafkaCo
相关文章
相关标签/搜索