/tmp/pear/install/rdkafka/rdkafka.c:662:19: note: each undeclared identifier is reported only once for each function it appears in
COPY_CONSTANT(RD_KAFKA_RESP_ERR__ISR_INSUFF);
^
/usr/include/php/20151012/Zend/zend_constants.h:42:105: note: in definition of macro ‘REGISTER_LONG_CONSTANT’
#define REGISTER_LONG_CONSTANT(name, lval, flags) zend_register_long_constant((name), sizeof(name)-1, (lval), (flags), module_number)
^
/tmp/pear/install/rdkafka/rdkafka.c:662:5: note: in expansion of macro ‘COPY_CONSTANT’
COPY_CONSTANT(RD_KAFKA_RESP_ERR__ISR_INSUFF);
^
make: *** [rdkafka.lo] Error 1
ERROR: `make' failed
thanks @edenhill - I've already set it to 1ms, but just going to upgrade to version 0.9.4 and see if that helps. Also, the way I was calling poll was with the following:
$this->getProducer()->poll(-1);
which from what I can gather waits until it gets a response. I tried changing to a while loop of $producer->poll(10);
etc but didn't see any difference - so are there any implications in using my original methodology of $this->getProducer()->poll(-1);
or any reasons not to do it that way etc?
$conf->set('client.id', 'track');
$conf->set('socket.blocking.max.ms', 1);
$conf->set('queue.buffering.max.ms', 1);
$conf->set('batch.num.messages', 1);