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 <[email protected]>
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
[email protected].
