private function initialize(array $brokers)
{
$conf = new ConsumerConf();
$conf->set('metadata.broker.list', implode(',', $brokers));
$consumer = new Consumer($conf);
$consumer->addBrokers(implode(',', $brokers));
$this->setConsumer($consumer);
}
$conf = new ConsumerConf();
$conf->set('metadata.broker.list', 'xx.xx.xx.xx:9092');
$consumer = new Consumer($conf);
%3|1479475193.723|ERROR|rdkafka#consumer-1| 127.0.0.1:9092/1001: Connect to ipv4#127.0.0.1:9092 failed: Connection refused
KAFKA_ADVERTISED_HOST_NAME: 127.0.0.1
#advertised.listeners=PLAINTEXT://your.host.name:9092
port=9092
create.topics=users:1:1
advertised.host.name=xx.xx.xx.xx
advertised.port=9092
PHP-rdkafka is a thin librdkafka binding providing a working PHP 5 / PHP 7 Kafka 0.8 / 0.9 client.
$rk = new RdKafka\Producer($conf);