Static producers: fix support for multiple custom properties for producer

Signed-off-by: Marios Andreopoulos <[email protected]>

Author: andmarios

filesystem/usr/local/share/landoop/sample-data/put.sh

@@ -8,7 +8,7 @@ for key in 0 1 2 3 4; do
     # Create topic with x partitions and a retention time of 10 years.
     kafka-topics \
         --zookeeper "${GENERATOR_ZK_HOST}:${ZK_PORT}" \
-            "${GENERATOR_PRODUCER_PROPERTIES}" \
+         ${GENERATOR_PRODUCER_PROPERTIES} \
         --topic "${TOPICS[key]}" \
         --partitions "${PARTITIONS[key]}" \
         --replication-factor "${REPLICATION[key]}" \
@@ -26,7 +26,7 @@ for key in 0 3 4; do
     /usr/local/bin/normcat -r 5000 "${DATA[key]}" | \
         kafka-avro-console-producer \
             --broker-list "${GENERATOR_BROKER}" \
-            "${GENERATOR_PRODUCER_PROPERTIES}" \
+            ${GENERATOR_PRODUCER_PROPERTIES} \
             --topic "${TOPICS[key]}" \
             --property parse.key=true \
             --property key.schema="$(cat "${KEYS[key]}")" \
@@ -43,7 +43,7 @@ for key in 1; do
     /usr/local/bin/normcat -r 5000 "${DATA[key]}" | \
         kafka-avro-console-producer \
             --broker-list "${GENERATOR_BROKER}" \
-            "${GENERATOR_PRODUCER_PROPERTIES}" \
+            ${GENERATOR_PRODUCER_PROPERTIES} \
             --topic "${TOPICS[key]}" \
             --property value.schema="$(cat "${VALUES[key]}")" \
             --property schema.registry.url="${GENERATOR_SCHEMA_REGISTRY_URL}"
@@ -59,7 +59,7 @@ for key in 2; do
         sed -r -e 's/([A-Z0-9-]*):/{"serial_number":"\1"}#/' | \
         kafka-console-producer \
             --broker-list "${GENERATOR_BROKER}" \
-            "${GENERATOR_PRODUCER_PROPERTIES}" \
+            ${GENERATOR_PRODUCER_PROPERTIES} \
             --topic "${TOPICS[key]}" \
             --property parse.key=true \
             --property "key.separator=#"

filesystem/usr/local/share/landoop/sample-data/running-telecom-italia.sh

@@ -29,7 +29,7 @@ for key in 4; do
     /usr/local/bin/normcat -v "${DATA[key]}" | \
         SCHEMA_REGISTRY_HEAP_OPTS="-Xmx50m" kafka-avro-console-producer \
             --broker-list "${GENERATOR_BROKER}" \
-            "${GENERATOR_PRODUCER_PROPERTIES}" \
+            ${GENERATOR_PRODUCER_PROPERTIES} \
             --topic "${TOPICS[key]}" \
             --property parse.key=true \
             --property key.schema="$(cat "${KEYS[key]}")" \