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; }