對於同一 組中的同一主題,Kafka
對同時連接(使用 Consumer.createJavaConsumerConnector創建)是否有限制?卡夫卡中的同一主題的消費者數量是否有限制?
我的情況是我需要消耗不同的過程(不 線程)的話題,所以我需要創建大量的高層次消費者的。
對於同一 組中的同一主題,Kafka
對同時連接(使用 Consumer.createJavaConsumerConnector創建)是否有限制?卡夫卡中的同一主題的消費者數量是否有限制?
我的情況是我需要消耗不同的過程(不 線程)的話題,所以我需要創建大量的高層次消費者的。
主要限制是擁有此主題的分區數 - 您可以創建比分區更多的消費者,但不會消耗任何東西。
同一消費羣組內的活動消費者數量受該主題分區數量的限制。額外的消費者將充當備份,並且只有當其中一個活躍消費者關閉並且該組被重新平衡時纔會開始消費。
如果您需要在多個進程中使用同一份數據,則您的消費者應該位於不同的消費羣體中。您可以擁有的消費者羣體數量沒有限制。