卡夫卡一個客戶一個分區

Question

我有一個使用案例，我有一個單獨的主題，其中有100個分區，每個分區的消息都帶有一些邏輯，我有100個消費者閱讀此消息。我想將特定的分區映射到特定的使用者。我怎樣才能做到這一點？

Answer 1

檢出卡夫卡消費者的Javadoc，特別是「手動分區分配」部分。

TL/DR

您可以手動分配特定的分區給消費者如下：

String topic = "foo"; 
TopicPartition partition0 = new TopicPartition(topic, 0); 
TopicPartition partition1 = new TopicPartition(topic, 1); 
consumer.assign(Arrays.asList(partition0, partition1));