See gh-14271
This commit is contained in:
Stephane Nicoll
2018-09-03 08:51:51 +02:00
parent 00233cd57e
commit 8950c3ebb4
2 changed files with 6 additions and 6 deletions

View File

@@ -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.
* connections to the Kafka cluster. Applies to all components unless overridden.
*/
private List<String> bootstrapServers = new ArrayList<>(
Collections.singletonList("localhost:9092"));
@@ -211,7 +211,7 @@ public class KafkaProperties {
/**
* Comma-delimited list of host:port pairs to use for establishing the initial
* connection to the Kafka cluster.
* connections to the Kafka cluster. Overrides the global property, for consumers.
*/
private List<String> bootstrapServers;
@@ -421,7 +421,7 @@ public class KafkaProperties {
/**
* Comma-delimited list of host:port pairs to use for establishing the initial
* connection to the Kafka cluster.
* connections to the Kafka cluster. Overrides the global property, for producers.
*/
private List<String> bootstrapServers;