add missing accessors for configuration properties' array members
This commit is contained in:
@@ -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;
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user