问题描述
我正在处理kafka和php，我是初学者，kafka已经在服务器上正确设置，
现在在本地 我已经安装： xamp/php 上的 librdkafka.dll 和 xamp/php/ext 上的 php_rdkafka.dll
我在 php.ini 添加了这个：
extension=php_rdkafka.dll
然后，我创建了一个包含以下代码的 php 页面：
$topic_name = '???';
$conf = new RdKafka\Conf();
$conf->set('metadata.broker.list',$broker_list);
$conf->set('enable.idempotence','true');
$conf->set('group.id',$topic_name);
$conf->set('sasl.username',"???");
$conf->set('sasl.mechanism',"PLAIN");
$conf->set('sasl.password',"???");
$conf->set('log_level',(string) LOG_DEBUG);
$conf->set('debug','all');
$producer = new RdKafka\Producer($conf);
$producer->addBrokers($broker_list);
$topic = $producer->newTopic($topic_name);
$topic->produce(RD_KAFKA_PARTITION_UA,"Message Test");
$producer->poll(0);
$result = $producer->flush(10000);```
but nothing returns on stream,could anyone help me?
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）