【问题标题】:How kafka producer at client side work?客户端的kafka生产者如何工作?
【发布时间】:2016-09-20 22:46:13
【问题描述】:

假设我拥有一个 kafka 集群,并且我要求一些客户端(Web 应用程序)将数据发送到 Kafka,我如何确保将创建生产者以连接到我的 Kafka 代理的客户端将执行分区如果客户端将使用自定义分区器,则以正确的方式?

【问题讨论】:

  • 这是错误的方式吗?我应该通过自己的制作人连接到这些应用程序吗?还是他们应该创建自己的生产者?

标签: apache-kafka


【解决方案1】:

AFAIK 无法限制 Kafka 客户端/集群使用某些分区程序。但是如果你的生产者隐藏在某个门面接口之后,你可能可以检查你的消息的Key是否以正确的方式创建。

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

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

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 2015-09-18
    • 2017-02-23
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2018-07-13
    相关资源
    最近更新 更多