在动态环境中使用 Apache Kafka

Question

我是 Kafka 新手，我使用的是 0.8.2 版本。我没有得到以下问题的答案。

1. 什么是分区键。

2. 如何在生产者端识别分区来发送消息。

3. 如果 kafka 集群中有 1 个代理，具有一个主题和分区。如果将新代理添加到集群，我的生产者正在发送消息。然后如何配置我的主题为新代理添加新分区。

等待您的回复。提前致谢。

阿南德

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
注意：根据上述网址，此工具仅在 0.8 分支中可用，您需要检查他们是否在新版本中提供了它。