X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2Fvim-emu.git;a=blobdiff_plain;f=src%2Femuvim%2Fapi%2Fosm%2Fkafka.py;h=c5f643f343ae96e5b11343b9a2c7c3c04ad50c40;hp=444362179625528f8c1e47034cb39c7ad1c74f01;hb=88e59cd5e0cc7745cb8d5fa90d0ba3bea6048ef2;hpb=f8f135c271341479200232641823520a541f33b0

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'