in_kafka: Append logs only for non zero length cases

Signed-off-by: Hiroshi Hatake <[email protected]>
fluent · Dec 19, 2023 · ac071a8 · ac071a8
1 parent e032ccf
commit ac071a8
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/plugins/in_kafka/in_kafka.c b/plugins/in_kafka/in_kafka.c
@@ -191,9 +191,11 @@ static int in_kafka_collect(struct flb_input_instance *ins,
     }
 
     if (ret == FLB_EVENT_ENCODER_SUCCESS) {
-        flb_input_log_append(ins, NULL, 0,
-                             ctx->log_encoder->output_buffer,
-                             ctx->log_encoder->output_length);
+        if (ctx->log_encoder->output_length > 0) {
+            flb_input_log_append(ins, NULL, 0,
+                                 ctx->log_encoder->output_buffer,
+                                 ctx->log_encoder->output_length);
+        }
         ret = 0;
     }
     else {