[nifi-minifi-cpp] branch main updated: MINIFICPP-1661 change PublishKafka Q.B.M.T. to 5ms

[ad...@apache.org]

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 <sz...@gmail.com>
AuthorDate: Mon Oct 18 10:40:50 2021 +0200

    MINIFICPP-1661 change PublishKafka Q.B.M.T. to 5ms
    
    Signed-off-by: Adam Debreceni <ad...@apache.org>
    
    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(