This is an automated email from the ASF dual-hosted git repository.
adebreceni pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
The following commit(s) were added to refs/heads/main by this push:
new 5f88639 MINIFICPP-1661 change PublishKafka Q.B.M.T. to 5ms
5f88639 is described below
commit 5f88639ffab840875a60c2862af436798faa776c
Author: Marton Szasz <[email protected]>
AuthorDate: Mon Oct 18 10:40:50 2021 +0200
MINIFICPP-1661 change PublishKafka Q.B.M.T. to 5ms
Signed-off-by: Adam Debreceni <[email protected]>
This closes #1194
---
extensions/librdkafka/PublishKafka.cpp | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/extensions/librdkafka/PublishKafka.cpp
b/extensions/librdkafka/PublishKafka.cpp
index 905dac8..97e14e3 100644
--- a/extensions/librdkafka/PublishKafka.cpp
+++ b/extensions/librdkafka/PublishKafka.cpp
@@ -96,7 +96,7 @@ const core::Property
PublishKafka::AttributeNameRegex("Attributes to Send as Hea
const core::Property PublishKafka::QueueBufferMaxTime(
core::PropertyBuilder::createProperty("Queue Buffering Max Time")
->isRequired(false)
- ->withDefaultValue<core::TimePeriodValue>("10 sec")
+ ->withDefaultValue<core::TimePeriodValue>("5 millis")
->withDescription("Delay to wait for messages in the producer queue to
accumulate before constructing message batches")
->build());
const core::Property PublishKafka::QueueBufferMaxSize(
