我是新来Kafka，我正在使用0.8.2版本。我没有得到下面问题的答案。什么是分区密钥。如何在生产者端识别分区以发送消息。如果kafka集群中有一个代理，并且有一个主题和分区。如果向集群中添加了新的代理，则我的生产者正在发送消息。然后如何配置我的主题为新代理添加新分区。等待你的答复。提前谢谢。阿南德
tv6aics11#
1） 分区键用于为要生成的任何消息定义目标分区。e、 g.您可以使用它来确定要发送到哪个分区的消息。2） 在 0.8.2 你可以这样做
0.8.2
ProducerRecord<String,String> producerRecord = new ProducerRecord<String,String>(topic, key, value);
3） 你可以用 add partition tool 位于 bin/kafka-add-partitions.sh 文件，以便在创建主题后向其添加分区。了解更多信息n、 b:根据上面的网址，这个工具只有在 0.8 branch，您需要检查他们是否在新版本中提供了它。
add partition tool
bin/kafka-add-partitions.sh
0.8
1条答案
按热度按时间tv6aics11#
1） 分区键用于为要生成的任何消息定义目标分区。e、 g.您可以使用它来确定要发送到哪个分区的消息。
2） 在
0.8.2你可以这样做3） 你可以用
add partition tool位于bin/kafka-add-partitions.sh文件，以便在创建主题后向其添加分区。了解更多信息n、 b:根据上面的网址，这个工具只有在
0.8branch，您需要检查他们是否在新版本中提供了它。