在動態環境中使用Apache Kafka

Question

我是Kafka的新手，我使用的是0.8.2版本。我沒有得到我以下問題的答案。

1. 什麼是分區鍵。

2. 如何識別生產者端發送消息的分區。

3. 如果1個經紀人在有一個主題和分區的卡夫卡羣集中。如果新代理添加到集羣，我的生產者正在發送消息。然後，如何配置我的主題以爲新代理添加新分區。

等待回覆。提前致謝。

Anand

Answer 1

1）分區鍵用於爲要生成的任何消息定義目標分區。例如您可以使用它來確定將哪個消息發送到哪個分區。

2）0.8.2，你可以做這樣的事情

ProducerRecord<String,String> producerRecord = new ProducerRecord<String,String>(topic, key, value); 

3）您可以使用位於bin/kafka-add-partitions.sh文件add partition tool一旦創建分區添加到一個主題。 Read more on this
N.B：根據上面的網址，這個工具只在0.8分支中可用，您需要檢查他們是否已經在新版本中使用它。