From da9fbdb63b6e50c57f3a8486e06e765f1eaf9487 Mon Sep 17 00:00:00 2001 From: Nico Hinderling Date: Fri, 5 Dec 2025 11:03:12 -0800 Subject: [PATCH] Set arroyo's max_pending_futures to 0 --- src/launchpad/kafka.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/launchpad/kafka.py b/src/launchpad/kafka.py index c41741f3..5f3e5a42 100644 --- a/src/launchpad/kafka.py +++ b/src/launchpad/kafka.py @@ -366,7 +366,7 @@ def get_kafka_config() -> KafkaConfig: group_id=group_id, topics=topics_env.split(","), concurrency=int(os.getenv("KAFKA_CONCURRENCY", "1")), - max_pending_futures=int(os.getenv("KAFKA_MAX_PENDING_FUTURES", "100")), + max_pending_futures=int(os.getenv("KAFKA_MAX_PENDING_FUTURES", "0")), auto_offset_reset=os.getenv("KAFKA_AUTO_OFFSET_RESET", "latest"), # latest = skip old messages arroyo_strict_offset_reset=arroyo_strict_offset_reset, security_protocol=os.environ.get("KAFKA_SECURITY_PROTOCOL", "plaintext"),