diff --git a/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfiguration.java b/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfiguration.java index 7f12d98ee1..9d73f58cd5 100644 --- a/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfiguration.java +++ b/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfiguration.java @@ -204,7 +204,7 @@ public class KafkaAutoConfiguration { private void applyKafkaConnectionDetailsForAdmin(Map properties, KafkaConnectionDetails connectionDetails) { - properties.put(CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, connectionDetails.getAdminBootstrapNodes()); + properties.put(CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, connectionDetails.getAdminBootstrapServers()); if (!(connectionDetails instanceof PropertiesKafkaConnectionDetails)) { properties.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, "PLAINTEXT"); } diff --git a/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaConnectionDetails.java b/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaConnectionDetails.java index cbcb535467..5490e9852e 100644 --- a/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaConnectionDetails.java +++ b/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaConnectionDetails.java @@ -31,38 +31,38 @@ import org.springframework.boot.autoconfigure.service.connection.ConnectionDetai public interface KafkaConnectionDetails extends ConnectionDetails { /** - * Returns the list of bootstrap nodes. - * @return the list of bootstrap nodes + * Returns the list of bootstrap servers. + * @return the list of bootstrap servers */ List getBootstrapServers(); /** - * Returns the list of bootstrap nodes used for consumers. - * @return the list of bootstrap nodes used for consumers + * Returns the list of bootstrap servers used for consumers. + * @return the list of bootstrap servers used for consumers */ default List getConsumerBootstrapServers() { return getBootstrapServers(); } /** - * Returns the list of bootstrap nodes used for producers. - * @return the list of bootstrap nodes used for producers + * Returns the list of bootstrap servers used for producers. + * @return the list of bootstrap servers used for producers */ default List getProducerBootstrapServers() { return getBootstrapServers(); } /** - * Returns the list of bootstrap nodes used for the admin. - * @return the list of bootstrap nodes used for the admin + * Returns the list of bootstrap servers used for the admin. + * @return the list of bootstrap servers used for the admin */ - default List getAdminBootstrapNodes() { + default List getAdminBootstrapServers() { return getBootstrapServers(); } /** - * Returns the list of bootstrap nodes used for Kafka Streams. - * @return the list of bootstrap nodes used for Kafka Streams + * Returns the list of bootstrap servers used for Kafka Streams. + * @return the list of bootstrap servers used for Kafka Streams */ default List getStreamsBootstrapServers() { return getBootstrapServers();