Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

delivery report callback do not return acknowledgement for every message #128

Open
kanchan1234 opened this issue Jun 27, 2017 · 2 comments

Comments

@kanchan1234
Copy link

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

@treziac
Copy link
Contributor

treziac commented Jun 27, 2017

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!

@kanchan1234
Copy link
Author

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

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants