Hello all,
I am working on a patch that will add intended topic name to the errorFile
produced by the omkafka module in the writeDataError function called from the
deliveryCallback.
Thanks for the contribution. We are actually moving to kafka, so will
benefit for that :)
The question I have is how to get the dynamic topic name inside either the
writeDataError or deliveryCallback functions.
The non-dynamic topic name is in the instance data so I can do:
jval = json_object_new_string(rd_kafka_topic_name(pData->pTopic));
json_object_object_add(json, "topic", jval);
Is there an easy way to access the post-template / intended topic name so I can
just put this in an if/else for the output JSON?
Thank you for any guidance,
Doesn't deliveryCallback get /rd_kafka_t////__attribute__//((unused))
*rk/ which may contain topic name?
https://github.com/edenhill/librdkafka/blob/b7f57f9863367feff64b743b651f4f51f0934581/src/rdkafka_int.h#L132
_______________________________________________
rsyslog mailing list
http://lists.adiscon.net/mailman/listinfo/rsyslog
http://www.rsyslog.com/professional-services/
What's up with rsyslog? Follow https://twitter.com/rgerhards
NOTE WELL: This is a PUBLIC mailing list, posts are ARCHIVED by a myriad of
sites beyond our control. PLEASE UNSUBSCRIBE and DO NOT POST if you DON'T LIKE
THAT.
