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)