在动态环境中使用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分支中可用，您需要检查他们是否已经在新版本中使用它。