LAM-33 The cluster data an internal network.

ansible/host_vars/master-node

-# Uncomment the following line and fill the IP address of the master node.
-# master_node_ip:
+internal_ip: "192.168.0.3"
 

ansible/host_vars/slave-1

+internal_ip: "192.168.0.2"
+
 ## Apache Kafka variables.
 id: 1
 

ansible/host_vars/slave-2

+internal_ip: "192.168.0.4"
+
 ## Apache Kafka variables.
 id: 2
 

ansible/roles/apache-flink/templates/flink-conf.j2

@@ -21,7 +21,7 @@
 # Common
 #==============================================================================
 
-jobmanager.rpc.address: {{ master_node_ip }}
+jobmanager.rpc.address: {{ internal_ip }}
 
 jobmanager.rpc.port: 6123
 

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

 ---
 - name: create topics
-  shell: "{{ installation_path }}/kafka/bin/kafka-topics.sh --create --zookeeper {{ hostvars['master-node']['master_node_ip'] }}:2181 --replication-factor {{ groups['slaves']|count + 1 }} --partitions 1 --topic input"
+  shell: "{{ installation_path }}/kafka/bin/kafka-topics.sh --create --zookeeper {{ hostvars['master-node']['internal_ip'] }}:2181 --replication-factor {{ groups['slaves']|count + 1 }} --partitions 1 --topic input"
   notify:
     - create batch output topic
 
 - name: create batch output topic
-  shell: "{{ installation_path }}/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"
+  shell: "{{ installation_path }}/kafka/bin/kafka-topics.sh --create --zookeeper {{ hostvars['master-node']['internal_ip'] }}:2181 --replication-factor {{ groups['slaves']|count + 1 }} --partitions 1 --topic batch-output"
   notify:
     - create stream output topic
 
 - name: create stream output topic
-  shell: "{{ installation_path }}/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"
+  shell: "{{ installation_path }}/kafka/bin/kafka-topics.sh --create --zookeeper {{ hostvars['master-node']['internal_ip'] }}:2181 --replication-factor {{ groups['slaves']|count + 1 }} --partitions 1 --topic stream-output"
 

ansible/roles/apache-kafka/templates/server.properties.j2

@@ -117,7 +117,7 @@ log.cleaner.enable=false
 # server. e.g. "127.0.0.1:3000,127.0.0.1:3001,127.0.0.1:3002".
 # You can also append an optional chroot string to the urls to specify the
 # root directory for all kafka znodes.
-zookeeper.connect={{ hostvars['master-node']['master_node_ip'] }}:2181
+zookeeper.connect={{ hostvars['master-node']['internal_ip'] }}:2181
 
 # Timeout in ms for connecting to zookeeper
 zookeeper.connection.timeout.ms=6000