Skip to content

Commit e0b7a13

Browse files
committed
Add npartitions parameter to the job
1 parent ff957a3 commit e0b7a13

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

chart/templates/configmap.yaml

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,9 @@ data:
4545
# Path to external avro schema. 'None' if not required.
4646
EXTERNAL_SCHEMA='None'
4747
48+
# Number of partitions for the producer
49+
NPARTITIONS=1
50+
4851
simulate_stream \
4952
-servers ${KAFKA_IPPORT} \
5053
-topic ${KAFKA_TOPIC} \
@@ -53,5 +56,6 @@ data:
5356
-nobservations ${NOBSERVATIONS} \
5457
-nalerts_per_obs $NALERTS_PER_OBS \
5558
-external_schema=${EXTERNAL_SCHEMA} \
56-
-to_display ${DISPLAY_FIELD}
59+
-to_display ${DISPLAY_FIELD} \
60+
-npartitions ${NPARTITIONS}
5761

0 commit comments

Comments
 (0)