You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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
The text was updated successfully, but these errors were encountered:
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!
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
The text was updated successfully, but these errors were encountered: