root
/
spring-boot
mirror of https://github.com/spring-projects/spring-boot.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #35733 from izeye 

* gh-35733:
  Name methods consistently in KafkaConnectionDetails

Closes gh-35733
This commit is contained in:
Andy Wilkinson 2023-06-30 11:26:39 +01:00
parent 3d15b02441 58a9961a31
commit 5bf7128224
2 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfiguration.java
View File

@ -204,7 +204,7 @@ public class KafkaAutoConfiguration {
private void applyKafkaConnectionDetailsForAdmin(Map<String, Object> 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");
}

22
spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/kafka/KafkaConnectionDetails.java
View File

@ -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<String> 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<String> 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<String> 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<String> getAdminBootstrapNodes() {
default List<String> 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<String> getStreamsBootstrapServers() {
return getBootstrapServers();