How to add a interceptor using librdkafka C++ client?

  apache-kafka, c++, librdkafka

I am trying to write a Kafka producer using librdkafka C++ client, I found there is no API to add a custom interceptor in C++ version, while i found some function to add interceptor in C which are not exposed in C++ client like

rd_kafka_resp_err_t
rd_kafka_interceptor_add_on_send (
        rd_kafka_t *rk, const char *ic_name,
        rd_kafka_interceptor_f_on_send_t *on_send,
        void *ic_opaque)

Source: Windows Questions C++

LEAVE A COMMENT