From a9e03f379e0d2eee3202163b23f9ceec992b75ab Mon Sep 17 00:00:00 2001 From: HaChanHo Date: Thu, 30 May 2024 19:14:38 +0900 Subject: [PATCH 1/2] in_kafka: Add async_commit description Signed-off-by: HaChanHo --- pipeline/inputs/kafka.md | 1 + 1 file changed, 1 insertion(+) diff --git a/pipeline/inputs/kafka.md b/pipeline/inputs/kafka.md index e779b6f07..492307450 100644 --- a/pipeline/inputs/kafka.md +++ b/pipeline/inputs/kafka.md @@ -15,6 +15,7 @@ This plugin uses the official [librdkafka C library](https://github.com/edenhill | poll\_ms | Kafka brokers polling interval in milliseconds. | 500 | | Buffer\_Max\_Size | Specify the maximum size of buffer per cycle to poll kafka messages from subscribed topics. To increase throughput, specify larger size. | 4M | | poll\_ms | Kafka brokers polling interval in milliseconds. | 500 | +| async_commit | Enable Kafka commit operation asynchronously. This option takes a boolean value: True/False. | False | | rdkafka.{property} | `{property}` can be any [librdkafka properties](https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md) | | ## Getting Started From 6cd0a721a20ba59f4bd3cf4227731b3379ccf47d Mon Sep 17 00:00:00 2001 From: champ-ion Date: Fri, 31 May 2024 01:25:38 +0900 Subject: [PATCH 2/2] in_kafka: Revise wording based on review feedback. Co-authored-by: Adam Locke Signed-off-by: champ-ion --- pipeline/inputs/kafka.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pipeline/inputs/kafka.md b/pipeline/inputs/kafka.md index 492307450..362f55a17 100644 --- a/pipeline/inputs/kafka.md +++ b/pipeline/inputs/kafka.md @@ -15,7 +15,7 @@ This plugin uses the official [librdkafka C library](https://github.com/edenhill | poll\_ms | Kafka brokers polling interval in milliseconds. | 500 | | Buffer\_Max\_Size | Specify the maximum size of buffer per cycle to poll kafka messages from subscribed topics. To increase throughput, specify larger size. | 4M | | poll\_ms | Kafka brokers polling interval in milliseconds. | 500 | -| async_commit | Enable Kafka commit operation asynchronously. This option takes a boolean value: True/False. | False | +| async_commit | Enable Kafka commit operation asynchronously. This parameter accepts a boolean value of `true` or `false`. | `false` | | rdkafka.{property} | `{property}` can be any [librdkafka properties](https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md) | | ## Getting Started