return;
}
#ifdef HAVE_LIBRDKAFKA_LOGGER
- rd_kafka_conf_set_logger(tctx->kafka, kafka_log);
+ rd_kafka_set_logger(tctx->kafka, kafka_log);
#endif
conf = NULL;
goto errout;
}
key = child->values[0].value.string;
- val = child->values[0].value.string;
+ val = child->values[1].value.string;
ret = rd_kafka_topic_conf_set(tctx->conf,key, val,
errbuf, sizeof(errbuf));
if (ret != RD_KAFKA_CONF_OK) {