我要安排Kafka制片人。。。我有一个有20个分区的主题,我已经验证了只有一个分区被填充在制作人下面设置
deyfvvtc1#
你必须提供更多的信息。对于给定的信息,我认为问题在于您对所有发送的消息都有相同的消息键,这会导致默认分区器分配相同的分区。如果是这样的话,你有两个选择:硬编码producerrecord中的分区号。创建自定义分区器。
1条答案
按热度按时间deyfvvtc1#
你必须提供更多的信息。
对于给定的信息,我认为问题在于您对所有发送的消息都有相同的消息键,这会导致默认分区器分配相同的分区。如果是这样的话,你有两个选择:
硬编码producerrecord中的分区号。
创建自定义分区器。