From 57fe2d453f7789676cd3cd17c56053e1d3ec9b8b Mon Sep 17 00:00:00 2001
From: akulavasu <34706681+akulavasu@users.noreply.github.com>
Date: Thu, 25 Jan 2024 16:53:58 +0530
Subject: [PATCH] Added kafka listener in server.properties (#1635)

Advertised listener added for kafka connectivity after bootstrap server connection is established.
---
 .../roles/ansible-kafka-upgrade/templates/server.properties.j2 | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/ansible/roles/ansible-kafka-upgrade/templates/server.properties.j2 b/ansible/roles/ansible-kafka-upgrade/templates/server.properties.j2
index 57ead422a9..f2eb0927fb 100644
--- 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