This repository was archived by the owner on Jun 10, 2022. It is now read-only.
This repository was archived by the owner on Jun 10, 2022. It is now read-only.
Producer problems with Kafka 0.9.0.0 #125
Open
Description
hello @nmred ,
最近在使用kafka-php的时候遇到了点问题,我本地环境的kafka-server是2.10-0.9.0.0。
在使用lib中的producer时设置了brokerVersion=0.9.0.0;但是发现没法正常地发送消息,消费者获取不到消息,而且topic也没办法正常使用了(写花了的感觉)。
后来试验发现,必须使用0.10.*版本(Version2打包协议)才能正常的发送消息,消费者也能正常消费,但是由于server是0.9.0.0,所以ack模式下,unpack又出现问题。
手动修改了lib代码,发现发送时使用Version2(0.10.*),unpack时使用Version1(0.9.*)才既能正常生产,又能正常解包。
很是奇怪,之前又没有人问过相关的issue,又不确定是不是lib出现的问题,还是本地kafka-server的问题。
特来请教一下,是lib使用方式的不对,还是别的什么问题?
谢谢~