【发布时间】:2016-09-20 22:46:13
【问题描述】:
假设我拥有一个 kafka 集群,并且我要求一些客户端(Web 应用程序)将数据发送到 Kafka,我如何确保将创建生产者以连接到我的 Kafka 代理的客户端将执行分区如果客户端将使用自定义分区器,则以正确的方式?
【问题讨论】:
-
这是错误的方式吗?我应该通过自己的制作人连接到这些应用程序吗?还是他们应该创建自己的生产者?
标签: apache-kafka
假设我拥有一个 kafka 集群,并且我要求一些客户端(Web 应用程序)将数据发送到 Kafka,我如何确保将创建生产者以连接到我的 Kafka 代理的客户端将执行分区如果客户端将使用自定义分区器,则以正确的方式?
【问题讨论】:
标签: apache-kafka
AFAIK 无法限制 Kafka 客户端/集群使用某些分区程序。但是如果你的生产者隐藏在某个门面接口之后,你可能可以检查你的消息的Key是否以正确的方式创建。
例如,您的外观可以接受ProducerRecords。在这种情况下,您可以访问 key 和 value 字段。
https://kafka.apache.org/090/javadoc/org/apache/kafka/clients/producer/ProducerRecord.html
【讨论】: