安装好了kafka-php扩展库，然后连接另一台服务器上的kafka，出错了

Question

显示扩展已经有啦，然后贴上我的代码如下：

$produce = KafkaProduce::getInstance('121...171:2181', 3000);

$produce->setRequireAck(-1);
$produce->setMessages('test', 0, array('test1111111'));
$result = $produce->send();
var_dump($result);

运行脚本报错如下：

请问是什么原因呢？
是连不上远程kafka服务器呢？
还是扩展问题？
kafka没装好？

Answer 1

问题已解答
使用扩展地址：https://github.com/arnaud-lb/...