客户端的卡夫卡生产者如何工作?

问题描述:

假设我拥有一个kafka集群,并且我要求一些客户端(web应用程序)向卡夫卡发送数据,我如何确保创建生产者的客户端连接到我的卡夫卡经纪人将执行分区如果客户端将使用自定义分区器,那么正确的方法是什么?客户端的卡夫卡生产者如何工作?

+0

这是错的呢?我应该通过我自己的制作者连接到这些应用吗?或者他们应该创建自己的生产者? –

AFAIK无法限制Kafka客户端/集群使用某个分区程序。但是如果您的制作人隐藏在某个外观界面的后面,您可能会检查您的信息的Key是否以正确的方式创建。

例如,您的外观可接受ProducerRecord s。在这种情况下,您可以访问keyvalue字段。

https://kafka.apache.org/090/javadoc/org/apache/kafka/clients/producer/ProducerRecord.html