LAM-33 Modified Apache Kafka variable and task names.

ansible/playbooks/tasks

+../tasks/
\ No newline at end of file

ansible/roles/apache-kafka/handlers/main.yml

 ---
 - name: create topics
-  shell: /usr/local/kafka/bin/kafka-topics.sh --create --zookeeper {{ hostvars['master-node']['kafka-ip'] }}:2181 --replication-factor {{ groups['slaves']|count + 1 }} --partitions 1 --topic input
+  shell: /usr/local/kafka/bin/kafka-topics.sh --create --zookeeper {{ hostvars['master-node']['master_node_ip'] }}:2181 --replication-factor {{ groups['slaves']|count + 1 }} --partitions 1 --topic input
   notify:
     - create batch output topic
 
 - name: create batch output topic
-  shell: /usr/local/kafka/bin/kafka-topics.sh --create --zookeeper {{ hostvars['master-node']['kafka-ip'] }}:2181 --replication-factor {{ groups['slaves']|count + 1 }} --partitions 1 --topic batch-output
+  shell: /usr/local/kafka/bin/kafka-topics.sh --create --zookeeper {{ hostvars['master-node']['master_node_ip'] }}:2181 --replication-factor {{ groups['slaves']|count + 1 }} --partitions 1 --topic batch-output
   notify:
     - create stream output topic
 
 - name: create stream output topic
-  shell: /usr/local/kafka/bin/kafka-topics.sh --create --zookeeper {{ hostvars['master-node']['kafka-ip'] }}:2181 --replication-factor {{ groups['slaves']|count + 1 }} --partitions 1 --topic stream-output
+  shell: /usr/local/kafka/bin/kafka-topics.sh --create --zookeeper {{ hostvars['master-node']['master_node_ip'] }}:2181 --replication-factor {{ groups['slaves']|count + 1 }} --partitions 1 --topic stream-output
 

ansible/roles/apache-kafka/tasks/download.yml

+---
+  - name: Download Apache Kafka.
+    get_url: url=http://mirrors.myaegean.gr/apache/kafka/0.8.2.1/kafka_2.10-0.8.2.1.tgz dest=/root/kafka_2.10-0.8.2.1.tgz
+    tags:
+      - download
+
+  - name: Uncompress Apache Kafka.
+    unarchive: src=/root/kafka_2.10-0.8.2.1.tgz dest=/usr/local copy=no
+    tags:
+      - download
+
+  - name: Create softlink for Apache Kafka.
+    file: src=/usr/local/kafka_2.10-0.8.2.1 dest=/usr/local/kafka state=link
+    tags:
+      - download
+

ansible/roles/apache-kafka/tasks/main.yml

 ---
   - name: Include common tasks.
-    include: common.yml
+    include: download.yml
+    tags:
+      - download
   
   - name: Include tasks for master.
     include: master.yml

ansible/roles/apache-kafka/tasks/slaves.yml

@@ -10,7 +10,7 @@
       - configure-kafka
 
   - name: Configure the Apache Zookeeper host.
-    lineinfile: dest=/usr/local/kafka/config/server.properties regexp="^zookeeper.connect=localhost:2181" line="zookeeper.connect={{ hostvars['master-node']['kafka-ip'] }}:2181"
+    lineinfile: dest=/usr/local/kafka/config/server.properties regexp="^zookeeper.connect=localhost:2181" line="zookeeper.connect={{ hostvars['master-node']['master_node_ip'] }}:2181"
     tags:
       - configure-kafka