From e97c5e0ba27844da11dab40aa20e2004dcba1482 Mon Sep 17 00:00:00 2001 From: luoyy8 Date: Sun, 15 Dec 2024 23:27:41 +0800 Subject: [PATCH] in_kafka: fix typo of debug log Signed-off-by: luoyy8 --- plugins/in_kafka/in_kafka.c | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/plugins/in_kafka/in_kafka.c b/plugins/in_kafka/in_kafka.c index 4db56e38d4c..ab21762b275 100644 --- a/plugins/in_kafka/in_kafka.c +++ b/plugins/in_kafka/in_kafka.c @@ -221,13 +221,14 @@ static int in_kafka_collect(struct flb_input_instance *ins, flb_plg_debug(ins, "kafka message received"); ret = process_message(ctx, rkm); - flb_plg_debug(ins, - "encode kafka message error, \ + + if (ret == FLB_EVENT_ENCODER_SUCCESS) { + flb_plg_debug(ins, + "parsed kafka message, \ topic: %s, offset: %s, partition: %s\n", rd_kafka_topic_name(rkm -> rkt), rkm->offset, rkm->partition); - if (ret == FLB_EVENT_ENCODER_SUCCESS) { if ( ctx -> auto_commit ) { rd_kafka_offset_store_message(rkm); }