@@ -164,7 +164,7 @@ static int in_kafka_collect(struct flb_input_instance *ins,
164164 /* Set the Kafka poll timeout based on execution mode:
165165 *
166166 * a) Running in the main event loop (non-threaded):
167- * - Use a minimal timeout (1ms - 10ms) to avoid blocking other inputs.
167+ * - Use a minimal timeout to avoid blocking other inputs.
168168 *
169169 * b) Running in a dedicated thread:
170170 * - Optimize for throughput by allowing Kafka's internal batching.
@@ -450,9 +450,9 @@ static struct flb_config_map config_map[] = {
450450 FLB_CONFIG_MAP_INT , "poll_timeout_ms" , "1" ,
451451 0 , FLB_TRUE , offsetof(struct flb_in_kafka_config , poll_timeout_ms ),
452452 "Set the timeout in milliseconds for Kafka consumer poll operations. "
453- "When running in the main event loop, use a low value (e.g., 1-10ms) to minimize blocking . "
454- "When running in a dedicated thread, a higher value (e.g., 1.5x - 2x 'librdkafka .fetch.wait.max.ms') "
455- "can improve efficiency by leveraging Kafka's batching."
453+ "This option only takes effect when running in a dedicated thread (i.e., when 'threaded' is enabled) . "
454+ "Using a higher timeout (e.g., 1.5x - 2x 'rdkafka .fetch.wait.max.ms') "
455+ "can improve efficiency by leveraging Kafka's batching mechanism ."
456456 },
457457 /* EOF */
458458 {0 }
0 commit comments