From: peusterm <manuel.peuster@uni-paderborn.de>
Date: Wed, 20 Mar 2019 07:00:53 +0000 (+0100)
Subject: Merge "Fixed setting kafka's advertised IP"
X-Git-Tag: v6.0.0~11
X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2Fvim-emu.git;a=commitdiff_plain;h=89ba0f3035cd734605bc6607871f8c6f1178df32;hp=b34cfac953b0f9a12b707e39a50e8bb4b1b4cb79

Merge "Fixed setting kafka's advertised IP"
---

diff --git a/src/emuvim/api/osm/kafka.py b/src/emuvim/api/osm/kafka.py
index 4443621..c5f643f 100644
--- a/src/emuvim/api/osm/kafka.py
+++ b/src/emuvim/api/osm/kafka.py
@@ -21,9 +21,11 @@ from emuvim.api.util.process_utils import wait_until
 class Kafka(OSMComponentBase):
     def __init__(self, net, ip, zookeeper_ip, version='latest', name_prefix=''):
         OSMComponentBase.__init__(self)
+        subnet_separator_index = ip.find('/')
+        ip_without_subnet = ip if subnet_separator_index == -1 else ip[:subnet_separator_index]
         self.instance = net.addDocker(
             '{}kafka'.format(name_prefix), ip=ip, dimage='wurstmeister/kafka:%s' % version,
-            environment={'KAFKA_ADVERTISED_HOST_NAME': ip,
+            environment={'KAFKA_ADVERTISED_HOST_NAME': ip_without_subnet,
                          'KAFKA_ADVERTISED_PORT': '9092',
                          'KAFKA_ZOOKEEPER_CONNECT': '%s:2181' % zookeeper_ip,
                          'KAFKA_CREATE_TOPICS': 'admin:1:1,ns:1:1,vim_account:1:1,wim_account:1:1,sdn:1:1,nsi:1:1'