delivery report callback do not return acknowledgement for every message

I am using librdkakfa 0.9.3 in RHOS i have set dr_msg_cb to get delivery report for each message here is the function def: static void dr_msg_cb (rd_kafka_t *rk,const rd_kafka_message_t *rkmessage, void opaque) { if (rkmessage->err) fprintf(stderr, "%% Message delivery failed: %s\n",rd_kafka_err2str(rkmessage->err)); else fprintf(stderr,"%% Message delivered (%zd bytes, " "Partition %"PRId32")\n", rkmessage->len, rkmessage->partition); / The rkmessage is destroyed automatically by librdkafka */ } function call: kafka_conf = rd_kafka_conf_new(); rd_kafka_conf_set_dr_msg_cb(kafka_conf, dr_msg_cb);

i observe that when i push 1k events to kafka producer I get '% Message delivered (32 bytes, Partition 6) " for 217 times..

How can i understand the number of messages actually received by consumer

Hi,

I think you meant to post in https://github.com/edenhill/librdkafka/issues Can you repost your issue there? If you can, try to use the latest version (0.9.5) to see if this solve problem. In all case, a code snippet of how you produce data would also help Thanks!

ok thanks for the reply..i wl repost the issue with code snippet