From 5b05637cd4f32484a61ea5575d3d531b55928f8c Mon Sep 17 00:00:00 2001 From: Matt Benson Date: Thu, 5 May 2016 10:16:43 -0500 Subject: [PATCH] add missing accessors for configuration properties' array members --- .../kafka/config/KafkaBinderConfigurationProperties.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/KafkaBinderConfigurationProperties.java b/spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/KafkaBinderConfigurationProperties.java index 9bf123074..2060b4aaa 100644 --- a/spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/KafkaBinderConfigurationProperties.java +++ b/spring-cloud-stream-binders/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/config/KafkaBinderConfigurationProperties.java @@ -93,6 +93,10 @@ public class KafkaBinderConfigurationProperties { return this.offsetUpdateShutdownTimeout; } + public String[] getZkNodes() { + return zkNodes; + } + public void setZkNodes(String[] zkNodes) { this.zkNodes = zkNodes; } @@ -101,6 +105,10 @@ public class KafkaBinderConfigurationProperties { this.defaultZkPort = defaultZkPort; } + public String[] getBrokers() { + return brokers; + } + public void setBrokers(String[] brokers) { this.brokers = brokers; } @@ -109,7 +117,6 @@ public class KafkaBinderConfigurationProperties { this.defaultBrokerPort = defaultBrokerPort; } - public void setHeaders(String[] headers) { this.headers = headers; }