Merge pull request #528 from aupodogov/set-publisher-ack-timeout-in-a…

…uto-configuration

KafkaPublisher Ack timeout can be set via properties and autoconfiguration

kafka-spring-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;
+        }
     }
 
     /**

kafka-spring-boot-autoconfigure/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();
     }