Kafka的assign和subscribe訂閱模式和手動提交偏移量

1、前言: 使用Apache Kafka消費者組時,有一個爲消費者分配對應分區partition的過程,咱們可使用「自動」subscribe和「手動」assign的方式。html KafkaConsumer.subscribe():爲consumer自動分配partition,有內部算法保證topic-partition以最優的方式均勻分配給同group下的不一樣consumer。 KafkaCo
相關文章
相關標籤/搜索