Repository: ambari Updated Branches: refs/heads/branch-2.4 a86300394 -> 4466b24b9
AMBARI-18340. Kafka acls setup is failing as part of atlas start (patch-II) Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/4466b24b Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/4466b24b Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/4466b24b Branch: refs/heads/branch-2.4 Commit: 4466b24b99fe71b9694519d377e93c2dcb4ac990 Parents: a863003 Author: Sumit Mohanty <smoha...@hortonworks.com> Authored: Fri Sep 9 11:37:27 2016 -0700 Committer: Sumit Mohanty <smoha...@hortonworks.com> Committed: Fri Sep 9 11:38:08 2016 -0700 ---------------------------------------------------------------------- .../common-services/ATLAS/0.1.0.2.3/package/scripts/params.py | 2 +- .../ATLAS/0.1.0.2.3/package/templates/atlas_kafka_acl.sh.j2 | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/4466b24b/ambari-server/src/main/resources/common-services/ATLAS/0.1.0.2.3/package/scripts/params.py ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/common-services/ATLAS/0.1.0.2.3/package/scripts/params.py b/ambari-server/src/main/resources/common-services/ATLAS/0.1.0.2.3/package/scripts/params.py index 91b7ae2..32e1510 100644 --- a/ambari-server/src/main/resources/common-services/ATLAS/0.1.0.2.3/package/scripts/params.py +++ b/ambari-server/src/main/resources/common-services/ATLAS/0.1.0.2.3/package/scripts/params.py @@ -249,7 +249,7 @@ host_with_kafka = hostname in hosts_with_kafka ranger_tagsync_hosts = default("/clusterHostInfo/ranger_tagsync_hosts", []) has_ranger_tagsync = len(ranger_tagsync_hosts) > 0 -ranger_user = default('/configurations/ranger-env/ranger_user', None) +rangertagsync_user = "rangertagsync" kafka_keytab = default('/configurations/kafka-env/kafka_keytab', None) kafka_principal_name = default('/configurations/kafka-env/kafka_principal_name', None) http://git-wip-us.apache.org/repos/asf/ambari/blob/4466b24b/ambari-server/src/main/resources/common-services/ATLAS/0.1.0.2.3/package/templates/atlas_kafka_acl.sh.j2 ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/common-services/ATLAS/0.1.0.2.3/package/templates/atlas_kafka_acl.sh.j2 b/ambari-server/src/main/resources/common-services/ATLAS/0.1.0.2.3/package/templates/atlas_kafka_acl.sh.j2 index ca7a85d..6a2edc6 100644 --- a/ambari-server/src/main/resources/common-services/ATLAS/0.1.0.2.3/package/templates/atlas_kafka_acl.sh.j2 +++ b/ambari-server/src/main/resources/common-services/ATLAS/0.1.0.2.3/package/templates/atlas_kafka_acl.sh.j2 @@ -37,5 +37,5 @@ create_topic ATLAS_ENTITIES {{kafka_home}}/bin/kafka-acls.sh --authorizer-properties zookeeper.connect={{kafka_zk_endpoint}} --add --topic ATLAS_ENTITIES --allow-principal User:{{metadata_user}} --producer {% if has_ranger_tagsync %} -{{kafka_home}}/bin/kafka-acls.sh --authorizer-properties zookeeper.connect={{kafka_zk_endpoint}} --add --topic ATLAS_ENTITIES --allow-principal User:{{ranger_user}} --consumer --group ranger_entities_consumer +{{kafka_home}}/bin/kafka-acls.sh --authorizer-properties zookeeper.connect={{kafka_zk_endpoint}} --add --topic ATLAS_ENTITIES --allow-principal User:{{rangertagsync_user}} --consumer --group ranger_entities_consumer {% endif %} \ No newline at end of file
