/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_zstd.c | 53 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 D | rdkafka_lz4.c | 64 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 D | rdkafka_sasl_cyrus.c | 106 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 D | rdkafka_broker.c | 239 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 D | rdkafka_msgset_reader.c | 285 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 D | rdkafka_idempotence.c | 288 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 D | rdkafka_sasl.c | 68 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 D | rdkafka_sasl_plain.c | 47 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 D | rdkafka_metadata.c | 311 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 D | rdkafka_zstd.c | 53 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 D | rdkafka_lz4.c | 64 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 D | rdkafka_sasl_cyrus.c | 104 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 D | rdkafka_broker.c | 218 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 D | rdkafka_metadata.c | 288 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 D | rdkafka_sasl.c | 68 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 D | rdkafka_msgset_reader.c | 283 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 D | rdkafka_sasl_plain.c | 47 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 D | rdkafka_zstd.c | 53 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 D | rdkafka_lz4.c | 64 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 D | rdkafka_sasl_cyrus.c | 106 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 D | rdkafka_broker.c | 233 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 D | rdkafka_msgset_reader.c | 285 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 D | rdkafka_idempotence.c | 288 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 D | rdkafka_sasl.c | 68 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 D | rdkafka_sasl_plain.c | 47 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()
|