生产端是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分区,不知为何,请大神们指教
kafka-php的问题,换成rdkafka就没问题了