diff --git a/cassandra4slurm/scripts/job.sh b/cassandra4slurm/scripts/job.sh
index d12a0b53..28da19e4 100755
--- a/cassandra4slurm/scripts/job.sh
+++ b/cassandra4slurm/scripts/job.sh
@@ -281,7 +281,7 @@ sleep 5
 if [ "X$STREAMING" != "X" ]; then
     if [ ${STREAMING,,} == "true" ]; then
         source $HECUBA_ROOT/bin/cassandra4slurm/launch_kafka.sh
-        launch_kafka $CASSANDRA_NODELIST $UNIQ_ID $N_NODES
+        launch_kafka $CASSFILE $UNIQ_ID $N_NODES
     fi
 fi
 
diff --git a/cassandra4slurm/scripts/launch_kafka.sh b/cassandra4slurm/scripts/launch_kafka.sh
index deff956a..0ac4cdf7 100644
--- a/cassandra4slurm/scripts/launch_kafka.sh
+++ b/cassandra4slurm/scripts/launch_kafka.sh
@@ -39,12 +39,13 @@ get_kafka_path () {
 }
 
 launch_kafka () {
-    local CASSANDRA_NODELIST="$1"
+    local CASSFILE="$1"
     local UNIQ_ID="$2"
     local N_NODES="$3"
 
-    local ZKNODE=$( get_first_node $CASSANDRA_NODELIST )
-    local ZKNODEIP=$( get_first_node $CASSANDRA_NODELIST.ips )
+    local ZKNODE=$( head -n 1 $CASSFILE )
+    local ZKNODEIP=$( head -n 1 $CASSFILE.ips )
+    local CASSANDRA_NODELIST=$(cat $CASSFILE | sed -e 's+ +,+g')
 
     KAFKA_PATH=$(get_kafka_path)