This is an automated email from the ASF dual-hosted git repository. mradhakrishnan pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/ambari.git
The following commit(s) were added to refs/heads/trunk by this push: new feb6f7d AMBARI-20908 : Kafka advertised.listeners replaced in Kerberos Mode (bharatviswa via mradhakrishnan) feb6f7d is described below commit feb6f7d9096ffc284bdc89f09035d289a1d73d48 Author: Madhuvanthi Radhakrishnan <mradhakrish...@hortonworks.com> AuthorDate: Tue Jan 30 11:49:59 2018 -0800 AMBARI-20908 : Kafka advertised.listeners replaced in Kerberos Mode (bharatviswa via mradhakrishnan) --- .../resources/common-services/KAFKA/0.8.1/package/scripts/kafka.py | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/ambari-server/src/main/resources/common-services/KAFKA/0.8.1/package/scripts/kafka.py b/ambari-server/src/main/resources/common-services/KAFKA/0.8.1/package/scripts/kafka.py index 3adea69..949f3a2 100644 --- a/ambari-server/src/main/resources/common-services/KAFKA/0.8.1/package/scripts/kafka.py +++ b/ambari-server/src/main/resources/common-services/KAFKA/0.8.1/package/scripts/kafka.py @@ -53,11 +53,7 @@ def kafka(upgrade_type=None): Logger.info(format("Kafka listeners: {listeners}")) kafka_server_config['listeners'] = listeners - if params.kerberos_security_enabled and params.kafka_kerberos_enabled: - Logger.info("Kafka kerberos security is enabled.") - kafka_server_config['advertised.listeners'] = listeners - Logger.info(format("Kafka advertised listeners: {listeners}")) - elif 'advertised.listeners' in kafka_server_config: + if 'advertised.listeners' in kafka_server_config: advertised_listeners = kafka_server_config['advertised.listeners'].replace("localhost", params.hostname) kafka_server_config['advertised.listeners'] = advertised_listeners Logger.info(format("Kafka advertised listeners: {advertised_listeners}")) -- To stop receiving notification emails like this one, please contact mradhakrish...@apache.org.