Commit cba49377 authored by Georgios Ouzounis's avatar Georgios Ouzounis
Browse files

LAM-30 Changed the default master-node name in apache-kafka role.

parent 25d0011c
---
- name: create topics
shell: /usr/local/kafka/bin/kafka-topics.sh --create --zookeeper {{ hostvars['master']['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']['kafka-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']['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']['kafka-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']['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']['kafka-ip'] }}:2181 --replication-factor {{ groups['slaves']|count + 1 }} --partitions 1 --topic stream-output
......@@ -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']['kafka-ip'] }}:2181"
lineinfile: dest=/usr/local/kafka/config/server.properties regexp="^zookeeper.connect=localhost:2181" line="zookeeper.connect={{ hostvars['master-node']['kafka-ip'] }}:2181"
tags:
- configure-kafka
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment