如何使用 librdkafka C++ 客户端添加拦截器？

问题描述

我正在尝试使用 librdkafka C++ 客户端编写一个 Kafka 生产者，我发现在 C++ 版本中没有添加自定义拦截器的 API，而我发现了一些在 C 中添加拦截器的函数，这些函数在 C++ 客户端中没有公开，例如

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)

解决方法

拦截器接口仅在 C 中可用，在 C++ 中不可用，但您可以（小心地）通过使用 c_*ptr() 方法检索 C 句柄，将底层 C 接口与 C++ 客户端一起使用。 例如，conf->c_global_ptr() 返回 C++ Conf 对象的底层 C rd_kafka_conf_t 对象。