Skip to content

Commit a6d5d67

Browse files
Set arroyo's max_pending_futures to 0 (#513)
1 parent 1e64b6b commit a6d5d67

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/launchpad/kafka.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -366,7 +366,7 @@ def get_kafka_config() -> KafkaConfig:
366366
group_id=group_id,
367367
topics=topics_env.split(","),
368368
concurrency=int(os.getenv("KAFKA_CONCURRENCY", "1")),
369-
max_pending_futures=int(os.getenv("KAFKA_MAX_PENDING_FUTURES", "100")),
369+
max_pending_futures=int(os.getenv("KAFKA_MAX_PENDING_FUTURES", "0")),
370370
auto_offset_reset=os.getenv("KAFKA_AUTO_OFFSET_RESET", "latest"), # latest = skip old messages
371371
arroyo_strict_offset_reset=arroyo_strict_offset_reset,
372372
security_protocol=os.environ.get("KAFKA_SECURITY_PROTOCOL", "plaintext"),

0 commit comments

Comments
 (0)