radhaagr
radhaagr
consumer is reading the same message after the poll. I tried different configuration values - "enable.auto.commit", "false" "offset.store.method", "true" "auto.offset.reset", "earliest" I have tried various combination of above config values...
Added consumer loop code - ``` while (!termFlag) { rd_kafka_message_t *rkm; rkm = rd_kafka_consumer_poll(m_rk, 300); /* Timeout: no message within 10ms, * try again. This short timeout allows * checking...
I tried the documentation but could not figure out how to get logging in my code - if (rd_kafka_conf_set(conf, "debug", "consumer,cgrp,topic,fetch", errstr, sizeof(errstr)) != RD_KAFKA_CONF_OK) { rd_kafka_conf_destroy(conf); return -1; }...
It will be great, if you can add an example for this to set rd_kafka_conf_set_log_cb as the web search did not help me much.
I tried to build the thunderSVM with VS 2019 and Cuda 10.2, but the build has failed with below error - Command to get the solution file- cmake .. -DCMAKE_WINDOWS_EXPORT_ALL_SYMBOLS=TRUE...