js-executor: fixed env variables mapping
This commit is contained in:
parent
9a4a94621a
commit
9ffa50f4a5
@ -27,9 +27,9 @@ kafka:
|
|||||||
servers: "TB_KAFKA_SERVERS"
|
servers: "TB_KAFKA_SERVERS"
|
||||||
replication_factor: "TB_QUEUE_KAFKA_REPLICATION_FACTOR"
|
replication_factor: "TB_QUEUE_KAFKA_REPLICATION_FACTOR"
|
||||||
acks: "TB_KAFKA_ACKS" # -1 = all; 0 = no acknowledgments; 1 = only waits for the leader to acknowledge
|
acks: "TB_KAFKA_ACKS" # -1 = all; 0 = no acknowledgments; 1 = only waits for the leader to acknowledge
|
||||||
batch_size: "${TB_KAFKA_BATCH_SIZE:128}" # for producer
|
batch_size: "TB_KAFKA_BATCH_SIZE" # for producer
|
||||||
linger_ms: "${TB_KAFKA_LINGER_MS:1}" # for producer
|
linger_ms: "TB_KAFKA_LINGER_MS" # for producer
|
||||||
partitions_consumed_concurrently: "${PARTITIONS_CONSUMED_CONCURRENTLY:1}" # increase this value if you are planning to handle more than one partition (scale up, scale down) - this will decrease the latency
|
partitions_consumed_concurrently: "TB_KAFKA_PARTITIONS_CONSUMED_CONCURRENTLY" # increase this value if you are planning to handle more than one partition (scale up, scale down) - this will decrease the latency
|
||||||
requestTimeout: "TB_QUEUE_KAFKA_REQUEST_TIMEOUT_MS"
|
requestTimeout: "TB_QUEUE_KAFKA_REQUEST_TIMEOUT_MS"
|
||||||
compression: "TB_QUEUE_KAFKA_COMPRESSION" # gzip or uncompressed
|
compression: "TB_QUEUE_KAFKA_COMPRESSION" # gzip or uncompressed
|
||||||
topic_properties: "TB_QUEUE_KAFKA_JE_TOPIC_PROPERTIES"
|
topic_properties: "TB_QUEUE_KAFKA_JE_TOPIC_PROPERTIES"
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user