1
當使用來自kafka的消息時,通常使用組id。但是,SimpleConsumer API只是使用clientName。clientName是組ID?當使用來自kafka的消息時,通常使用組id。但是,SimpleConsumer只使用clientName。clientName是組ID?
當使用來自kafka的消息時,通常使用組id。但是,SimpleConsumer API只是使用clientName。clientName是組ID?當使用來自kafka的消息時,通常使用組id。但是,SimpleConsumer只使用clientName。clientName是組ID?
對於SimpleConsumer,clientName只是客戶端的標識符。它不是組ID。事實上,SimpleConsumer中沒有消費者羣體的概念。
請參閱documentation - 使用SimpleConsumer實現的主要原因是您希望比消費者組給您更好地控制分區消耗。
High Level Consumer有消費羣體的概念。
'group.id'字符串定義了此進程正在使用的使用者組。
消費者集團是在一個特定的消息僅由屬於同一組
很好的回答了消費者的一個消費高層次的概念,謝謝 – yongzhi