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

Question

我正在尝试使用 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)

Answer 1

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