Lines Matching refs:rd_rkb_dbg
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()
349 rd_rkb_dbg(msetr->msetr_rkb, MSG, "SNAPPY", in rd_kafka_msgset_reader_decompress()
363 rd_rkb_dbg(msetr->msetr_rkb, MSG, "SNAPPY", in rd_kafka_msgset_reader_decompress()
378 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()
1353 rd_rkb_dbg(msetr->msetr_rkb, FETCH, "CONSUME", in rd_kafka_msgset_reader_run()
1385 rd_rkb_dbg(msetr->msetr_rkb, MSG | RD_KAFKA_DBG_FETCH, "CONSUME", in rd_kafka_msgset_reader_run()