Merge branch '2.0.x'
This commit is contained in:
@@ -57,7 +57,7 @@ public class KafkaProperties {
|
||||
|
||||
/**
|
||||
* Comma-delimited list of host:port pairs to use for establishing the initial
|
||||
* connection to the Kafka cluster. Applies to all components unless overridden.
|
||||
* connections to the Kafka cluster. Applies to all components unless overridden.
|
||||
*/
|
||||
private List<String> bootstrapServers = new ArrayList<>(
|
||||
Collections.singletonList("localhost:9092"));
|
||||
@@ -230,7 +230,7 @@ public class KafkaProperties {
|
||||
|
||||
/**
|
||||
* Comma-delimited list of host:port pairs to use for establishing the initial
|
||||
* connection to the Kafka cluster. Overrides the global property, for consumers.
|
||||
* connections to the Kafka cluster. Overrides the global property, for consumers.
|
||||
*/
|
||||
private List<String> bootstrapServers;
|
||||
|
||||
@@ -440,7 +440,7 @@ public class KafkaProperties {
|
||||
|
||||
/**
|
||||
* Comma-delimited list of host:port pairs to use for establishing the initial
|
||||
* connection to the Kafka cluster. Overrides the global property, for producers.
|
||||
* connections to the Kafka cluster. Overrides the global property, for producers.
|
||||
*/
|
||||
private List<String> bootstrapServers;
|
||||
|
||||
|
||||
Reference in New Issue
Block a user