Merge branch '3.1.x'

Closes gh-36133
pull/35874/head
Andy Wilkinson 1 year ago
commit 8fa80426b4

@ -204,7 +204,7 @@ public class KafkaAutoConfiguration {
private void applyKafkaConnectionDetailsForAdmin(Map<String, Object> properties, private void applyKafkaConnectionDetailsForAdmin(Map<String, Object> properties,
KafkaConnectionDetails connectionDetails) { KafkaConnectionDetails connectionDetails) {
properties.put(CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, connectionDetails.getAdminBootstrapNodes()); properties.put(CommonClientConfigs.BOOTSTRAP_SERVERS_CONFIG, connectionDetails.getAdminBootstrapServers());
if (!(connectionDetails instanceof PropertiesKafkaConnectionDetails)) { if (!(connectionDetails instanceof PropertiesKafkaConnectionDetails)) {
properties.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, "PLAINTEXT"); properties.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, "PLAINTEXT");
} }

@ -31,38 +31,38 @@ import org.springframework.boot.autoconfigure.service.connection.ConnectionDetai
public interface KafkaConnectionDetails extends ConnectionDetails { public interface KafkaConnectionDetails extends ConnectionDetails {
/** /**
* Returns the list of bootstrap nodes. * Returns the list of bootstrap servers.
* @return the list of bootstrap nodes * @return the list of bootstrap servers
*/ */
List<String> getBootstrapServers(); List<String> getBootstrapServers();
/** /**
* Returns the list of bootstrap nodes used for consumers. * Returns the list of bootstrap servers used for consumers.
* @return the list of bootstrap nodes used for consumers * @return the list of bootstrap servers used for consumers
*/ */
default List<String> getConsumerBootstrapServers() { default List<String> getConsumerBootstrapServers() {
return getBootstrapServers(); return getBootstrapServers();
} }
/** /**
* Returns the list of bootstrap nodes used for producers. * Returns the list of bootstrap servers used for producers.
* @return the list of bootstrap nodes used for producers * @return the list of bootstrap servers used for producers
*/ */
default List<String> getProducerBootstrapServers() { default List<String> getProducerBootstrapServers() {
return getBootstrapServers(); return getBootstrapServers();
} }
/** /**
* Returns the list of bootstrap nodes used for the admin. * Returns the list of bootstrap servers used for the admin.
* @return the list of bootstrap nodes used for the admin * @return the list of bootstrap servers used for the admin
*/ */
default List<String> getAdminBootstrapNodes() { default List<String> getAdminBootstrapServers() {
return getBootstrapServers(); return getBootstrapServers();
} }
/** /**
* Returns the list of bootstrap nodes used for Kafka Streams. * Returns the list of bootstrap servers used for Kafka Streams.
* @return the list of bootstrap nodes used for Kafka Streams * @return the list of bootstrap servers used for Kafka Streams
*/ */
default List<String> getStreamsBootstrapServers() { default List<String> getStreamsBootstrapServers() {
return getBootstrapServers(); return getBootstrapServers();

Loading…
Cancel
Save