Skip to content

T
trackrdrd
Commit a15d6ab9 authored by Geoff Simmons's avatar Geoff Simmons
Browse files
Options

MQ plugin for Kafka: only log full message on delivery failure when 

                     log level is DEBUG
parent c433051c
Hide whitespace changes
Inline Side-by-side
Showing with 9 additions and 4 deletions
trackrdrd/src/mq/kafka/callback.c
View file @ a15d6ab9
......@@ -96,10 +96,15 @@ CB_DeliveryReport(rd_kafka_t *rk, void *payload, size_t len,
CHECK_OBJ_NOTNULL(wrk, KAFKA_WRK_MAGIC);
if (err != RD_KAFKA_RESP_ERR_NO_ERROR) {
MQ_LOG_Log(LOG_ERR,
"Delivery error %d (client ID = %s, msg = [%.*s]): %s",
err, rd_kafka_name(rk), (int) len, (char *) payload,
rd_kafka_err2str(err));
if (loglvl == LOG_DEBUG)
MQ_LOG_Log(LOG_DEBUG,
"Delivery error %d (client ID = %s), msg = [%.*s]: %s",
err, rd_kafka_name(rk), (int) len, (char *) payload,
rd_kafka_err2str(err));
else
MQ_LOG_Log(LOG_ERR,
"Delivery error %d (client ID = %s): %s",
err, rd_kafka_name(rk), rd_kafka_err2str(err));
wrk->failed++;
}
else {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment