[airavata] branch staging updated: Fixing permission issue in kafka ansibles

[dimuthuupe]

This is an automated email from the ASF dual-hosted git repository.

dimuthuupe pushed a commit to branch staging
in repository https://gitbox.apache.org/repos/asf/airavata.git


The following commit(s) were added to refs/heads/staging by this push:
     new e1a88de  Fixing permission issue in kafka ansibles
e1a88de is described below

commit e1a88de724511b6820a474ab11b9f43c368af22c
Author: Dimuthu Wannipurage <dimuthu.upeks...@gmail.com>
AuthorDate: Mon Apr 15 16:16:47 2019 -0400

    Fixing permission issue in kafka ansibles
---
 dev-tools/ansible/roles/kafka/handlers/main.yml | 6 ++++++
 dev-tools/ansible/roles/kafka/tasks/main.yml    | 4 +++-
 2 files changed, 9 insertions(+), 1 deletion(-)

diff --git a/dev-tools/ansible/roles/kafka/handlers/main.yml 
b/dev-tools/ansible/roles/kafka/handlers/main.yml
index 223fd9b..9856989 100644
--- a/dev-tools/ansible/roles/kafka/handlers/main.yml
+++ b/dev-tools/ansible/roles/kafka/handlers/main.yml
@@ -22,18 +22,24 @@
 # Kafka related handlers
 - name: start kafka
   service: name=kafka state=started enabled=yes
+  become: yes
 
 - name: stop kafka
   service: name=kafka state=stopped enabled=yes
+  become: yes
 
 - name: restart kafka
   service: name=kafka state=restarted enabled=yes
+  become: yes
 
 - name: start kafka-rest-proxy
   service: name=kafka-rest-proxy state=started enabled=yes
+  become: yes
 
 - name: stop kafka-rest-proxy
   service: name=kafka-rest-proxy state=stopped enabled=yes
+  become: yes
 
 - name: restart kafka-rest-proxy
   service: name=kafka-rest-proxy state=restarted enabled=yes
+  become: yes
diff --git a/dev-tools/ansible/roles/kafka/tasks/main.yml 
b/dev-tools/ansible/roles/kafka/tasks/main.yml
index a0ee36a..f0eeb24 100644
--- a/dev-tools/ansible/roles/kafka/tasks/main.yml
+++ b/dev-tools/ansible/roles/kafka/tasks/main.yml
@@ -24,6 +24,7 @@
 - name: Check kafka package availability
   stat: path={{ kafka_dir }}
   register: kafka_package
+  become: yes
 
 # Download Kafka
 - name: Download and unarchive Kafka from {{ kafka_tgz_url }}
@@ -38,6 +39,7 @@
 # Create kafka logs directory
 - name: Create kafka logs directory
   file: path="{{ kafka_dir }}/logs" state=directory owner={{ user }} group={{ 
group }}
+  become: yes
 
 # Config kafka server and start
 - name: Copy kafka server properties file
@@ -65,7 +67,7 @@
   with_items:
     - "{{ kafka_listener_port }}/tcp"
     - "{{ kafka_rest_proxy_listener_port }}/tcp"
-  become_user: root
+  become: yes
 
 - name: systemd install kafka service script
   template: src=kafka.service.j2