These are chat archives for arnaud-lb/php-rdkafka

12th
Dec 2016
Nastasia Saby
@NastasiaSaby
Dec 12 2016 10:32
@edenhill Hi, I tried it but it still does not work.
@edenhill My configuration is : rdkafka : 2.0.1, librdkafka : 0.9, kafka : 0.10, PHP7. I can send you my code if you want. It is the "high level consumer" example "https://arnaud-lb.github.io/php-rdkafka/phpdoc/rdkafka.examples-high-level-consumer.html". I have only added this : $topicConf->set('enable.auto.commit', 0);
Magnus Edenhill
@edenhill
Dec 12 2016 10:38
@NastasiaSaby what exact librdkafka version?
the high-level consumer uses global configuration properties ("enable.auto.commit"), not topic-level configuration ("auto.commit.enable")
Nastasia Saby
@NastasiaSaby
Dec 12 2016 10:38

rdkafka

rdkafka support => enabled
version => 2.0.1
build date => Dec 12 2016 10:13:42
librdkafka version (runtime) => 0.9.2-112-g7f12b7
librdkafka version (build) => 0.9.3.0

Magnus Edenhill
@edenhill
Dec 12 2016 10:39
$topicConf->set("enable.auto.commit", ..) should actually fail since that is a global property
Nastasia Saby
@NastasiaSaby
Dec 12 2016 10:39
Ok so do I have to change my kafka config to add an "enable.auto.commit" option in the servier_properties ?
Thank you for your quick answer by the way
Magnus Edenhill
@edenhill
Dec 12 2016 10:41
no, thats a global client property
librdkafka config is split up in Global properties and per-topic per properties. The high-level consumer uses the Global properties (since you typically dont instantiate topic objects when using it)
That doc has two sections, one for Global and one for Topic
Nastasia Saby
@NastasiaSaby
Dec 12 2016 10:43
Ok but where can I change this option?
On the config of the kafkaCOnsumer ?
Magnus Edenhill
@edenhill
Dec 12 2016 10:47
yeah
$conf->set("enable.auto.commit", "false")
Nastasia Saby
@NastasiaSaby
Dec 12 2016 12:21
It seems to work \O/ \O/. Thank you so much for your help.
Magnus Edenhill
@edenhill
Dec 12 2016 12:22
:+1: