$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
port=9092 create.topics=users:1:1 advertised.host.name=xx.xx.xx.xx advertised.port=9092
$rk = new RdKafka\Producer($conf);
@edenhill thanks for replying! appreciated - I have this offset bug that I can't figure out - maybe you can spot something?
My consumer here that i've built - using STORED offset. The bug behaviour is:
Did this make sense ?