Added kafka listener in server.properties (#1635)

Advertised listener added for kafka connectivity after bootstrap server connection is established.
Sunbird-Obsrv · Jan 25, 2024 · 57fe2d4 · 57fe2d4
1 parent 49d7f23
commit 57fe2d4
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/ansible/roles/ansible-kafka-upgrade/templates/server.properties.j2 b/ansible/roles/ansible-kafka-upgrade/templates/server.properties.j2
@@ -6,6 +6,9 @@
   {%- if url_host == ansible_fqdn or url_host in ansible_all_ipv4_addresses -%}
 broker.id={{loop.index0 + 1}}
 
+# Kafka connection string
+advertised.listeners=PLAINTEXT://{% for host in groups['zookeeper'] %}{{ hostvars[host].inventory_hostname }}:{{kafka_port}}{% if not loop.last %},{% endif %}{% endfor %}
+
 ############################# Socket Server Settings #############################
 
 # The port the socket server listens on