KafkaPublisher Ack timeout can be set via properties and autoconfigur…

…ation
AxonFramework · Sep 9, 2024 · a4e2be0 · a4e2be0
1 parent f2e9c2d
commit a4e2be0
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 0 deletions.
diff --git a/...-boot-autoconfigure/src/main/java/org/axonframework/extensions/kafka/KafkaProperties.java b/...-boot-autoconfigure/src/main/java/org/axonframework/extensions/kafka/KafkaProperties.java
@@ -234,6 +234,12 @@ public static class Publisher {
          */
         private String processingGroup = DEFAULT_PROCESSING_GROUP;
 
+        /**
+         * The publisher acknowledge timeout in milliseconds specifying how long to wait for a publisher to
+         * acknowledge a message has been sent. Defaults to {@code 1000} milliseconds.
+         */
+        private long ackTimeout = 1000;
+
         public boolean isEnabled() {
             return enabled;
         }
@@ -257,6 +263,14 @@ public String getProcessingGroup() {
         public void setProcessingGroup(String processingGroup) {
             this.processingGroup = processingGroup;
         }
+
+        public long getAckTimeout() {
+            return ackTimeout;
+        }
+
+        public void setAckTimeout(long ackTimeout) {
+            this.ackTimeout = ackTimeout;
+        }
     }
 
     /**

diff --git a/...e/src/main/java/org/axonframework/extensions/kafka/autoconfig/KafkaAutoConfiguration.java b/...e/src/main/java/org/axonframework/extensions/kafka/autoconfig/KafkaAutoConfiguration.java
@@ -176,6 +176,7 @@ public TopicResolver topicResolver() {
                              .messageConverter(kafkaMessageConverter)
                              .messageMonitor(configuration.messageMonitor(KafkaPublisher.class, "kafkaPublisher"))
                              .topicResolver(topicResolver)
+                             .publisherAckTimeout(properties.getPublisher().getAckTimeout())
                              .build();
     }