ソースを参照

change default of producer.wait-after-send to 0

Grega Bremec 7 ヶ月 前
コミット
1a29458539

+ 1 - 1
code/core-api-consumer/src/main/resources/META-INF/microprofile-config.properties

@@ -9,7 +9,7 @@ ssl.truststore.password = FIXME
 # producer.num-rolls =                      # 1
 # producer.num-records-per-roll =           # 100
 # producer.wait-after-roll =                # 5000
-# producer.wait-after-send =                # 500
+# producer.wait-after-send =                # 0
 # producer.local-id =                       # -1 (for log file only)
 # producer.payload-trunc =                  # false
 

+ 1 - 1
code/core-api-producer/src/main/java/com/redhat/training/kafka/coreapi/producer/Producer.java

@@ -106,7 +106,7 @@ public class Producer {
         int howManyrolls = ConfigProvider.getConfig().getOptionalValue("producer.num-rolls", Integer.class).orElse(1);
         int sendSize = ConfigProvider.getConfig().getOptionalValue("producer.num-records-per-roll", Integer.class).orElse(100);
         int waitAfterBatch = ConfigProvider.getConfig().getOptionalValue("producer.wait-after-roll", Integer.class).orElse(5000);
-        int waitAfterSend = ConfigProvider.getConfig().getOptionalValue("producer.wait-after-send", Integer.class).orElse(500);
+        int waitAfterSend = ConfigProvider.getConfig().getOptionalValue("producer.wait-after-send", Integer.class).orElse(0);
         int localId = ConfigProvider.getConfig().getOptionalValue("producer.local-id", Integer.class).orElse(-1);
         boolean truncPayload = ConfigProvider.getConfig().getOptionalValue("producer.payload-trunc", Boolean.class).orElse(false);
 

+ 1 - 1
code/core-api-producer/src/main/resources/META-INF/microprofile-config.properties

@@ -9,7 +9,7 @@ ssl.truststore.password = FIXME
 # producer.num-rolls =                      # 1
 # producer.num-records-per-roll =           # 100
 # producer.wait-after-roll =                # 5000
-# producer.wait-after-send =                # 500
+# producer.wait-after-send =                # 0
 # producer.local-id =                       # -1 (for log file only)
 # producer.payload-trunc =                  # false