`buffer.memory` konfigurierbar gemacht

diff --git a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
index 3666233415c799cab7a6926ca85ff253e007b64d..7540dd33a35e68a3244c81fbe2b8f9507219c78e 100644 (file)
--- a/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
+++ b/src/main/java/de/juplo/kafka/ApplicationConfiguration.java
@@ -42,6 +42,7 @@ public class ApplicationConfiguration
     props.put("acks", properties.getProducerProperties().getAcks());
     props.put("delivery.timeout.ms", (int)properties.getProducerProperties().getDeliveryTimeout().toMillis());
     props.put("max.block.ms", (int)properties.getProducerProperties().getMaxBlock().toMillis());
+    props.put("buffer.memory", properties.getProducerProperties().getBufferMemory());
     props.put("batch.size", properties.getProducerProperties().getBatchSize());
     props.put("metadata.max.age.ms",  5000); //  5 Sekunden
     props.put("request.timeout.ms",   5000); //  5 Sekunden

diff --git a/src/main/java/de/juplo/kafka/ApplicationProperties.java b/src/main/java/de/juplo/kafka/ApplicationProperties.java
index 594fa28dc5235091902f2dbc684ceec445f7548b..43232628755882f32117ac1a72c5ade16dd13f1e 100644 (file)
--- a/src/main/java/de/juplo/kafka/ApplicationProperties.java
+++ b/src/main/java/de/juplo/kafka/ApplicationProperties.java
@@ -49,6 +49,8 @@ public class ApplicationProperties
     @NotNull
     private Duration maxBlock;
     @NotNull
+    private Long bufferMemory;
+    @NotNull
     private Integer batchSize;
     @NotNull
     private Duration linger;

diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 4c6519d536a28a69a217cd7dce68caaae46d4d9c..98ea128410ff81794392869d222cbfe8c452a0d3 100644 (file)
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -6,6 +6,7 @@ juplo:
     acks: -1
     delivery-timeout: 10s
     max-block: 5s
+    buffer-memory: 33554432
     batch-size: 16384
     linger: 0
     compression-type: gzip
@@ -32,6 +33,7 @@ info:
       acks: ${juplo.producer.acks}
       delivery-timeout: ${juplo.producer.delivery-timeout}
       max-block: ${juplo.producer.max-block}
+      buffer-memory: ${juplo.producer.buffer-memory}
       batch-size: ${juplo.producer.batch-size}
       linger: ${juplo.producer.linger}
       compression-type: ${juplo.producer.compression-type}