假设我拥有一个kafka集群，我请求一些客户机（web应用程序）向kafka发送数据，如果客户机将使用自定义分区器，我如何确保将创建生产者以连接到我的kafka代理的客户机以正确的方式进行分区？
ddarikpa1#
恐怕不可能限制kafka客户机/集群使用某些分区器。但是如果您的生产者隐藏在某个facade接口后面，您可能可以检查 Key 你的信息已经以正确的方式创建。你的外表可以接受 ProducerRecord 举个例子。在这种情况下，您可以访问 key 以及 value 领域。https://kafka.apache.org/090/javadoc/org/apache/kafka/clients/producer/producerrecord.html
Key
ProducerRecord
key
value
1条答案
按热度按时间ddarikpa1#
恐怕不可能限制kafka客户机/集群使用某些分区器。但是如果您的生产者隐藏在某个facade接口后面，您可能可以检查
Key你的信息已经以正确的方式创建。你的外表可以接受
ProducerRecord举个例子。在这种情况下，您可以访问key以及value领域。https://kafka.apache.org/090/javadoc/org/apache/kafka/clients/producer/producerrecord.html