Kafka生产者相同的key却写入到不同的partition中

生产端是php, 使用的是kafka-php, 生产时指定了key
消费端是python, 使用的是kafka-python
kafka版本是2.10
消费时打印消息的相关信息

log.info(
    "%s:%s:%d:%d" % (message.topic, message.key, message.partition, message.offset)
)

打印的信息如下

[2021-12-08 10:52:39,340] aaabbb:b'21120910523861b16f76ea270':0:2316114
[2021-12-08 10:52:39,463] aaabbb:b'21120910523861b16f76ea270':1:1509741

按我的理解,应该相同的key到相同的partion,但这里分别到了0分区和1分区,不知为何,请大神们指教

阅读 2.7k
1 个回答

kafka-php的问题,换成rdkafka就没问题了

撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进