Log partition of the failed write request to Kafka

Having this information helps narrowing down the problematic kafka host.
adjust · Jan 20, 2021 · 4364315 · 4364315
1 parent c083112
commit 4364315
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/kafka.c b/src/kafka.c
@@ -14,7 +14,7 @@ static void
 dr_msg_cb (UNUSED rd_kafka_t *rk, const rd_kafka_message_t *rkmessage, UNUSED void *opaque)
 {
     if (rkmessage->err)
-        logger_log("%s %d: Message delivery failed: %s\n", __FILE__, __LINE__, rd_kafka_err2str(rkmessage->err));
+        logger_log("%s %d: Message delivery failed: %s partition: %d\n", __FILE__, __LINE__, rd_kafka_err2str(rkmessage->err), rkmessage->partition);
 }
 
 static void