summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorEugene Chekanskiy <echekanskiy@gmail.com>2018-06-01 14:22:21 +0300
committerEugene Chekanskiy <echekanskiy@hortonworks.com>2018-06-01 16:28:54 +0300
commitb79e4be51bdf8067958e17998f4e61c92ed98556 (patch)
treeaff6606e9809b1036964584b169ab1a01aa8dfa1
parentc043401740470f6930c230e66780ba2b30432b1b (diff)
AMBARI-24010. Fix kafka_extended_sasl_support version check (echekanskiy)
-rw-r--r--ambari-server/src/main/resources/common-services/KAFKA/0.8.1/package/scripts/params.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/ambari-server/src/main/resources/common-services/KAFKA/0.8.1/package/scripts/params.py b/ambari-server/src/main/resources/common-services/KAFKA/0.8.1/package/scripts/params.py
index f07cba8a89..722fe7ce19 100644
--- a/ambari-server/src/main/resources/common-services/KAFKA/0.8.1/package/scripts/params.py
+++ b/ambari-server/src/main/resources/common-services/KAFKA/0.8.1/package/scripts/params.py
@@ -172,7 +172,7 @@ kafka_kerberos_enabled = (('security.inter.broker.protocol' in config['configura
kafka_other_sasl_enabled = not kerberos_security_enabled and check_stack_feature(StackFeature.KAFKA_LISTENERS, stack_version_formatted) and \
- check_stack_feature(StackFeature.KAFKA_EXTENDED_SASL_SUPPORT, stack_version_formatted) and \
+ check_stack_feature(StackFeature.KAFKA_EXTENDED_SASL_SUPPORT, format_stack_version(version_for_stack_feature_checks)) and \
(("SASL_PLAINTEXT" in config['configurations']['kafka-broker']['listeners']) or
("PLAINTEXTSASL" in config['configurations']['kafka-broker']['listeners']) or
("SASL_SSL" in config['configurations']['kafka-broker']['listeners']))