Function rd_kafka_interceptor_add_on_commit

pub unsafe extern "C" fn rd_kafka_interceptor_add_on_commit(
    rk: *mut rd_kafka_t,
    ic_name: *const c_char,
    on_commit: rd_kafka_interceptor_f_on_commit_t,
    ic_opaque: *mut c_void,
) -> rd_kafka_resp_err_t

Append an on_commit() interceptor.

• rk: Client instance.
• ic_name: Interceptor name, used in logging.
• on_commit(): Function pointer.
• ic_opaque: Opaque value that will be passed to the function.

Returns RD_KAFKA_RESP_ERR_NO_ERROR on success or RD_KAFKA_RESP_ERR__CONFLICT if an existing interceptor with the same ic_name and function has already been added to conf.