kafka知識(partition group)

1.group.id是標識消費者的ID。每一個group.id消費後,kafka會記錄該id消費的offset到zookeeper。所以,此處需要注意,(1)如果多個地方都使用相同的groupid,可能造成個別消費者消費不到的情況(2)如果單個消費者消費能力不足的話,可以啓動多個相同groupid的consumer消費,處理相同的邏輯。但是,多線程的時候,需要增加每個groupid下的partit
相關文章
相關標籤/搜索