Home
last modified time | relevance | path

Searched refs:rd_rkb_dbg (Results 1 – 25 of 66) sorted by relevance

123

/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_zstd.c53 rd_rkb_dbg(rkb, MSG, "ZSTD", in rd_kafka_zstd_decompress()
71 rd_rkb_dbg(rkb, MSG, "ZSTD", in rd_kafka_zstd_decompress()
100 rd_rkb_dbg(rkb, MSG, "ZSTD", in rd_kafka_zstd_decompress()
108 rd_rkb_dbg(rkb, MSG, "ZSTD", in rd_kafka_zstd_decompress()
133 rd_rkb_dbg(rkb, MSG, "ZSTDCOMPR", in rd_kafka_zstd_compress()
143 rd_rkb_dbg(rkb, MSG, "ZSTDCOMPR", in rd_kafka_zstd_compress()
158 rd_rkb_dbg(rkb, MSG, "ZSTDCOMPR", in rd_kafka_zstd_compress()
170 rd_rkb_dbg(rkb, MSG, "ZSTDCOMPR", in rd_kafka_zstd_compress()
190 rd_rkb_dbg(rkb, MSG, "ZSTDCOMPR", in rd_kafka_zstd_compress()
200 rd_rkb_dbg(rkb, MSG, "ZSTDCOMPR", in rd_kafka_zstd_compress()
H A Drdkafka_lz4.c64 rd_rkb_dbg(rkb, BROKER, "LZ4FIXUP", in rd_kafka_lz4_decompress_fixup_bad_framing()
79 rd_rkb_dbg(rkb, BROKER, "LZ4FIXUP", in rd_kafka_lz4_decompress_fixup_bad_framing()
123 rd_rkb_dbg(rkb, BROKER, "LZ4FIXDOWN", in rd_kafka_lz4_compress_break_framing()
138 rd_rkb_dbg(rkb, BROKER, "LZ4FIXUP", in rd_kafka_lz4_compress_break_framing()
186 rd_rkb_dbg(rkb, BROKER, "LZ4DECOMPR", in rd_kafka_lz4_decompress()
291 rd_rkb_dbg(rkb, MSG, "LZ4DEC", in rd_kafka_lz4_decompress()
353 rd_rkb_dbg(rkb, MSG, "LZ4COMPR", in rd_kafka_lz4_compress()
362 rd_rkb_dbg(rkb, MSG, "LZ4COMPR", in rd_kafka_lz4_compress()
371 rd_rkb_dbg(rkb, MSG, "LZ4COMPR", in rd_kafka_lz4_compress()
380 rd_rkb_dbg(rkb, MSG, "LZ4COMPR", in rd_kafka_lz4_compress()
[all …]
H A Drdkafka_sasl_cyrus.c106 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "SASL", in rd_kafka_sasl_cyrus_recv()
138 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "SASL", in rd_kafka_sasl_cyrus_recv()
165 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "SASL", in rd_kafka_sasl_cyrus_recv()
319 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "LIBSASL", in rd_kafka_sasl_cyrus_cb_getopt()
343 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "LIBSASL", in rd_kafka_sasl_cyrus_cb_log()
372 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "LIBSASL", in rd_kafka_sasl_cyrus_cb_getsimple()
395 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "LIBSASL", in rd_kafka_sasl_cyrus_cb_getsecret()
412 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "LIBSASL", in rd_kafka_sasl_cyrus_cb_chalprompt()
427 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "LIBSASL", in rd_kafka_sasl_cyrus_cb_getrealm()
455 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "LIBSASL", in rd_kafka_sasl_cyrus_cb_canon()
[all …]
H A Drdkafka_broker.c239 rd_rkb_dbg(rkb, BROKER, "FEATURE", in rd_kafka_broker_features_set()
1765 rd_rkb_dbg(rkb, BROKER, "RESPONSE", in rd_kafka_req_response()
1783 rd_rkb_dbg(rkb, PROTOCOL, "RECV", in rd_kafka_req_response()
2111 rd_rkb_dbg(rkb, BROKER, "CONNECT", in rd_kafka_broker_connect()
2236 rd_rkb_dbg(rkb, in rd_kafka_broker_handle_SaslHandshake()
2436 rd_rkb_dbg(rkb, in rd_kafka_broker_handle_ApiVersion()
2673 rd_rkb_dbg(rkb, PROTOCOL, "SEND", in rd_kafka_send()
2704 rd_rkb_dbg(rkb, PROTOCOL, "SEND", in rd_kafka_send()
4635 rd_rkb_dbg(rkb, MSG, "FETCH", in rd_kafka_fetch_reply_handle()
4942 rd_rkb_dbg(rkb, FETCH, "FETCH", in rd_kafka_broker_fetch_toppars()
[all …]
H A Drdkafka_msgset_reader.c285 rd_rkb_dbg(msetr->msetr_rkb, MSG, "GZIP", in rd_kafka_msgset_reader_decompress()
330 rd_rkb_dbg(msetr->msetr_rkb, MSG, "SNAPPY", in rd_kafka_msgset_reader_decompress()
425 rd_rkb_dbg(msetr->msetr_rkb, MSG, "CODEC", in rd_kafka_msgset_reader_decompress()
753 rd_rkb_dbg(msetr->msetr_rkb, MSG, "MSG", in rd_kafka_msgset_reader_msg_v2()
786 rd_rkb_dbg(msetr->msetr_rkb, MSG, "MSG", in rd_kafka_msgset_reader_msg_v2()
824 rd_rkb_dbg(msetr->msetr_rkb, in rd_kafka_msgset_reader_msg_v2()
847 rd_rkb_dbg(msetr->msetr_rkb, in rd_kafka_msgset_reader_msg_v2()
865 rd_rkb_dbg(msetr->msetr_rkb, MSG, "TXN" in rd_kafka_msgset_reader_msg_v2()
977 rd_rkb_dbg(msetr->msetr_rkb, MSG, "MSG", in rd_kafka_msgset_reader_msgs_v2()
1199 rd_rkb_dbg(msetr->msetr_rkb, in rd_kafka_msgset_reader_peek_msg_version()
[all …]
H A Drdkafka_idempotence.c288 rd_rkb_dbg(rkb, EOS, "GETPID", in rd_kafka_idemp_pid_fsm()
297 rd_rkb_dbg(rkb, EOS, "GETPID", in rd_kafka_idemp_pid_fsm()
315 rd_rkb_dbg(rkb, EOS, "GETPID", "Acquiring ProducerId"); in rd_kafka_idemp_pid_fsm()
330 rd_rkb_dbg(rkb, EOS, "GETPID", in rd_kafka_idemp_pid_fsm()
415 rd_rkb_dbg(rkb, EOS, "GETPID", in rd_kafka_idemp_request_pid_failed()
468 rd_rkb_dbg(rkb, EOS, "GETPID", in rd_kafka_idemp_pid_update()
H A Drdkafka_sasl.c68 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "SASL", in rd_kafka_sasl_send_legacy()
97 rd_rkb_dbg(rkb, SECURITY, "SASL", in rd_kafka_sasl_send()
141 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "SASL", in rd_kafka_sasl_recv()
258 rd_rkb_dbg(rkb, SECURITY, "SASL", in rd_kafka_sasl_client_new()
H A Drdkafka_sasl_plain.c47 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "SASLPLAIN", in rd_kafka_sasl_plain_recv()
93 rd_rkb_dbg(rkb, SECURITY, "SASLPLAIN", in rd_kafka_sasl_plain_client_new()
H A Drdkafka_metadata.c311 rd_rkb_dbg(rkb, METADATA, in rd_kafka_parse_Metadata()
320 rd_rkb_dbg(rkb, METADATA, "METADATA", "%i brokers, %i topics", in rd_kafka_parse_Metadata()
456 rd_rkb_dbg(rkb, METADATA, "METADATA", in rd_kafka_parse_Metadata()
464 rd_rkb_dbg(rkb, METADATA, "METADATA", in rd_kafka_parse_Metadata()
477 rd_rkb_dbg(rkb, METADATA, "METADATA", in rd_kafka_parse_Metadata()
488 rd_rkb_dbg(rkb, TOPIC, "BLACKLIST", in rd_kafka_parse_Metadata()
499 rd_rkb_dbg(rkb, TOPIC, "METADATA", in rd_kafka_parse_Metadata()
530 rd_rkb_dbg(rkb, TOPIC, "METADATA", in rd_kafka_parse_Metadata()
536 rd_rkb_dbg(rkb, TOPIC, "METADATA", "wanted %s", in rd_kafka_parse_Metadata()
590 rd_rkb_dbg(rkb, BROKER, "CONTROLLERID", in rd_kafka_parse_Metadata()
[all …]
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/
H A Drdkafka_zstd.c53 rd_rkb_dbg(rkb, MSG, "ZSTD", in rd_kafka_zstd_decompress()
71 rd_rkb_dbg(rkb, MSG, "ZSTD", in rd_kafka_zstd_decompress()
100 rd_rkb_dbg(rkb, MSG, "ZSTD", in rd_kafka_zstd_decompress()
108 rd_rkb_dbg(rkb, MSG, "ZSTD", in rd_kafka_zstd_decompress()
133 rd_rkb_dbg(rkb, MSG, "ZSTDCOMPR", in rd_kafka_zstd_compress()
143 rd_rkb_dbg(rkb, MSG, "ZSTDCOMPR", in rd_kafka_zstd_compress()
158 rd_rkb_dbg(rkb, MSG, "ZSTDCOMPR", in rd_kafka_zstd_compress()
170 rd_rkb_dbg(rkb, MSG, "ZSTDCOMPR", in rd_kafka_zstd_compress()
190 rd_rkb_dbg(rkb, MSG, "ZSTDCOMPR", in rd_kafka_zstd_compress()
200 rd_rkb_dbg(rkb, MSG, "ZSTDCOMPR", in rd_kafka_zstd_compress()
H A Drdkafka_lz4.c64 rd_rkb_dbg(rkb, BROKER, "LZ4FIXUP", in rd_kafka_lz4_decompress_fixup_bad_framing()
79 rd_rkb_dbg(rkb, BROKER, "LZ4FIXUP", in rd_kafka_lz4_decompress_fixup_bad_framing()
123 rd_rkb_dbg(rkb, BROKER, "LZ4FIXDOWN", in rd_kafka_lz4_compress_break_framing()
138 rd_rkb_dbg(rkb, BROKER, "LZ4FIXUP", in rd_kafka_lz4_compress_break_framing()
186 rd_rkb_dbg(rkb, BROKER, "LZ4DECOMPR", in rd_kafka_lz4_decompress()
291 rd_rkb_dbg(rkb, MSG, "LZ4DEC", in rd_kafka_lz4_decompress()
353 rd_rkb_dbg(rkb, MSG, "LZ4COMPR", in rd_kafka_lz4_compress()
362 rd_rkb_dbg(rkb, MSG, "LZ4COMPR", in rd_kafka_lz4_compress()
371 rd_rkb_dbg(rkb, MSG, "LZ4COMPR", in rd_kafka_lz4_compress()
380 rd_rkb_dbg(rkb, MSG, "LZ4COMPR", in rd_kafka_lz4_compress()
[all …]
H A Drdkafka_sasl_cyrus.c104 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "SASL", in rd_kafka_sasl_cyrus_recv()
136 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "SASL", in rd_kafka_sasl_cyrus_recv()
163 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "SASL", in rd_kafka_sasl_cyrus_recv()
301 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "LIBSASL", in rd_kafka_sasl_cyrus_cb_getopt()
312 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "LIBSASL", in rd_kafka_sasl_cyrus_cb_log()
340 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "LIBSASL", in rd_kafka_sasl_cyrus_cb_getsimple()
363 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "LIBSASL", in rd_kafka_sasl_cyrus_cb_getsecret()
380 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "LIBSASL", in rd_kafka_sasl_cyrus_cb_chalprompt()
395 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "LIBSASL", in rd_kafka_sasl_cyrus_cb_getrealm()
423 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "LIBSASL", in rd_kafka_sasl_cyrus_cb_canon()
[all …]
H A Drdkafka_broker.c218 rd_rkb_dbg(rkb, BROKER, "FEATURE", in rd_kafka_broker_features_set()
508 rd_rkb_dbg(rkb, BROKER, "BRKTERM", in rd_kafka_broker_fail()
1554 rd_rkb_dbg(rkb, PROTOCOL, "RECV", in rd_kafka_req_response()
1866 rd_rkb_dbg(rkb, BROKER, "CONNECT", in rd_kafka_broker_connect()
1992 rd_rkb_dbg(rkb, in rd_kafka_broker_handle_SaslHandshake()
2195 rd_rkb_dbg(rkb, in rd_kafka_broker_handle_ApiVersion()
2393 rd_rkb_dbg(rkb, PROTOCOL, "SEND", in rd_kafka_send()
2424 rd_rkb_dbg(rkb, PROTOCOL, "SEND", in rd_kafka_send()
4164 rd_rkb_dbg(rkb, MSG, "FETCH", in rd_kafka_fetch_reply_handle()
4571 rd_rkb_dbg(rkb, FETCH, "FETCH", in rd_kafka_broker_fetch_toppars()
[all …]
H A Drdkafka_metadata.c288 rd_rkb_dbg(rkb, METADATA, in rd_kafka_parse_Metadata()
297 rd_rkb_dbg(rkb, METADATA, "METADATA", "%i brokers, %i topics", in rd_kafka_parse_Metadata()
433 rd_rkb_dbg(rkb, METADATA, "METADATA", in rd_kafka_parse_Metadata()
441 rd_rkb_dbg(rkb, METADATA, "METADATA", in rd_kafka_parse_Metadata()
454 rd_rkb_dbg(rkb, METADATA, "METADATA", in rd_kafka_parse_Metadata()
465 rd_rkb_dbg(rkb, TOPIC, "BLACKLIST", in rd_kafka_parse_Metadata()
476 rd_rkb_dbg(rkb, TOPIC, "METADATA", in rd_kafka_parse_Metadata()
511 rd_rkb_dbg(rkb, TOPIC, "METADATA", in rd_kafka_parse_Metadata()
517 rd_rkb_dbg(rkb, TOPIC, "METADATA", "wanted %s", in rd_kafka_parse_Metadata()
551 rd_rkb_dbg(rkb, BROKER, "CONTROLLERID", in rd_kafka_parse_Metadata()
[all …]
H A Drdkafka_sasl.c68 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "SASL", in rd_kafka_sasl_send_legacy()
97 rd_rkb_dbg(rkb, SECURITY, "SASL", in rd_kafka_sasl_send()
141 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "SASL", in rd_kafka_sasl_recv()
258 rd_rkb_dbg(rkb, SECURITY, "SASL", in rd_kafka_sasl_client_new()
H A Drdkafka_msgset_reader.c283 rd_rkb_dbg(msetr->msetr_rkb, MSG, "GZIP", in rd_kafka_msgset_reader_decompress()
328 rd_rkb_dbg(msetr->msetr_rkb, MSG, "SNAPPY", in rd_kafka_msgset_reader_decompress()
347 rd_rkb_dbg(msetr->msetr_rkb, MSG, "SNAPPY", in rd_kafka_msgset_reader_decompress()
361 rd_rkb_dbg(msetr->msetr_rkb, MSG, "SNAPPY", in rd_kafka_msgset_reader_decompress()
423 rd_rkb_dbg(msetr->msetr_rkb, MSG, "CODEC", in rd_kafka_msgset_reader_decompress()
746 rd_rkb_dbg(msetr->msetr_rkb, MSG, "MSG", in rd_kafka_msgset_reader_msg_v2()
779 rd_rkb_dbg(msetr->msetr_rkb, MSG, "MSG", in rd_kafka_msgset_reader_msg_v2()
853 rd_rkb_dbg(msetr->msetr_rkb, MSG, "TXN" in rd_kafka_msgset_reader_msg_v2()
1098 rd_rkb_dbg(msetr->msetr_rkb, MSG, "MSG", in rd_kafka_msgset_reader_v2()
1173 rd_rkb_dbg(msetr->msetr_rkb, in rd_kafka_msgset_reader_peek_msg_version()
[all …]
H A Drdkafka_sasl_plain.c47 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "SASLPLAIN", in rd_kafka_sasl_plain_recv()
93 rd_rkb_dbg(rkb, SECURITY, "SASLPLAIN", in rd_kafka_sasl_plain_client_new()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/
H A Drdkafka_zstd.c53 rd_rkb_dbg(rkb, MSG, "ZSTD",
71 rd_rkb_dbg(rkb, MSG, "ZSTD",
100 rd_rkb_dbg(rkb, MSG, "ZSTD",
108 rd_rkb_dbg(rkb, MSG, "ZSTD",
133 rd_rkb_dbg(rkb, MSG, "ZSTDCOMPR",
143 rd_rkb_dbg(rkb, MSG, "ZSTDCOMPR",
158 rd_rkb_dbg(rkb, MSG, "ZSTDCOMPR",
170 rd_rkb_dbg(rkb, MSG, "ZSTDCOMPR",
190 rd_rkb_dbg(rkb, MSG, "ZSTDCOMPR",
200 rd_rkb_dbg(rkb, MSG, "ZSTDCOMPR",
H A Drdkafka_lz4.c64 rd_rkb_dbg(rkb, BROKER, "LZ4FIXUP",
79 rd_rkb_dbg(rkb, BROKER, "LZ4FIXUP",
123 rd_rkb_dbg(rkb, BROKER, "LZ4FIXDOWN",
138 rd_rkb_dbg(rkb, BROKER, "LZ4FIXUP",
186 rd_rkb_dbg(rkb, BROKER, "LZ4DECOMPR", in pg_atomic_compare_exchange_u32_impl()
291 rd_rkb_dbg(rkb, MSG, "LZ4DEC", in pg_atomic_compare_exchange_u32_impl()
353 rd_rkb_dbg(rkb, MSG, "LZ4COMPR",
362 rd_rkb_dbg(rkb, MSG, "LZ4COMPR",
371 rd_rkb_dbg(rkb, MSG, "LZ4COMPR",
380 rd_rkb_dbg(rkb, MSG, "LZ4COMPR",
[all …]
H A Drdkafka_sasl_cyrus.c106 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "SASL",
138 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "SASL",
165 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "SASL",
319 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "LIBSASL",
343 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "LIBSASL",
372 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "LIBSASL",
395 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "LIBSASL",
412 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "LIBSASL",
427 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "LIBSASL",
455 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "LIBSASL",
[all …]
H A Drdkafka_broker.c233 rd_rkb_dbg(rkb, BROKER, "FEATURE", in rd_kafka_broker_features_set()
1752 rd_rkb_dbg(rkb, BROKER, "RESPONSE", in rd_kafka_req_response()
1770 rd_rkb_dbg(rkb, PROTOCOL, "RECV", in rd_kafka_req_response()
2098 rd_rkb_dbg(rkb, BROKER, "CONNECT", in rd_kafka_broker_connect()
2223 rd_rkb_dbg(rkb, in rd_kafka_broker_handle_SaslHandshake()
2423 rd_rkb_dbg(rkb, in rd_kafka_broker_handle_ApiVersion()
2625 rd_rkb_dbg(rkb, PROTOCOL, "SEND", in rd_kafka_send()
2656 rd_rkb_dbg(rkb, PROTOCOL, "SEND", in rd_kafka_send()
4580 rd_rkb_dbg(rkb, MSG, "FETCH", in rd_kafka_fetch_reply_handle()
4887 rd_rkb_dbg(rkb, FETCH, "FETCH", in rd_kafka_broker_fetch_toppars()
[all …]
H A Drdkafka_msgset_reader.c285 rd_rkb_dbg(msetr->msetr_rkb, MSG, "GZIP", in rd_kafka_msgset_reader_decompress()
330 rd_rkb_dbg(msetr->msetr_rkb, MSG, "SNAPPY", in rd_kafka_msgset_reader_decompress()
425 rd_rkb_dbg(msetr->msetr_rkb, MSG, "CODEC", in rd_kafka_msgset_reader_decompress()
753 rd_rkb_dbg(msetr->msetr_rkb, MSG, "MSG", in rd_kafka_msgset_reader_msg_v2()
786 rd_rkb_dbg(msetr->msetr_rkb, MSG, "MSG", in rd_kafka_msgset_reader_msg_v2()
824 rd_rkb_dbg(msetr->msetr_rkb, in rd_kafka_msgset_reader_msg_v2()
847 rd_rkb_dbg(msetr->msetr_rkb, in rd_kafka_msgset_reader_msg_v2()
865 rd_rkb_dbg(msetr->msetr_rkb, MSG, "TXN" in rd_kafka_msgset_reader_msg_v2()
977 rd_rkb_dbg(msetr->msetr_rkb, MSG, "MSG", in rd_kafka_msgset_reader_msgs_v2()
1199 rd_rkb_dbg(msetr->msetr_rkb, in rd_kafka_msgset_reader_peek_msg_version()
[all …]
H A Drdkafka_idempotence.c288 rd_rkb_dbg(rkb, EOS, "GETPID", in rd_buf_write_ensure()
297 rd_rkb_dbg(rkb, EOS, "GETPID", in rd_buf_write_ensure()
315 rd_rkb_dbg(rkb, EOS, "GETPID", "Acquiring ProducerId"); in rd_buf_write_ensure()
330 rd_rkb_dbg(rkb, EOS, "GETPID", in rd_buf_write_ensure()
415 rd_rkb_dbg(rkb, EOS, "GETPID", in rd_buf_get_writable()
468 rd_rkb_dbg(rkb, EOS, "GETPID",
H A Drdkafka_sasl.c68 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "SASL", in rd_kafka_sasl_send_legacy()
97 rd_rkb_dbg(rkb, SECURITY, "SASL", in rd_kafka_sasl_send()
141 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "SASL", in rd_kafka_sasl_recv()
258 rd_rkb_dbg(rkb, SECURITY, "SASL", in rd_kafka_sasl_client_new()
H A Drdkafka_sasl_plain.c47 rd_rkb_dbg(rktrans->rktrans_rkb, SECURITY, "SASLPLAIN", in rd_kafka_sasl_plain_recv()
93 rd_rkb_dbg(rkb, SECURITY, "SASLPLAIN", in rd_kafka_sasl_plain_client_new()

123