Skip to content

Commit 9d06e81

Browse files
Silthusclaude
andcommitted
refactor(messaging): write the email status kafka consumer count as is
Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
1 parent 546f5b8 commit 9d06e81

1 file changed

Lines changed: 1 addition & 2 deletions

File tree

‎products/messaging/backend/models/email_status_sql.py‎

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,6 @@
44
CONSUMER_GROUP_EMAIL_STATUS,
55
KAFKA_COLUMNS_WITH_PARTITION,
66
kafka_engine,
7-
kafka_num_consumers,
87
ttl_period,
98
)
109
from posthog.clickhouse.table_engines import Distributed, ReplacingMergeTree, ReplicationScheme
@@ -84,7 +83,7 @@
8483
)
8584
}
8685
SETTINGS kafka_skip_broken_messages = 100,
87-
kafka_num_consumers = {kafka_num_consumers(1)},
86+
kafka_num_consumers = 1,
8887
kafka_thread_per_consumer = 1,
8988
kafka_poll_timeout_ms = 10000,
9089
kafka_max_block_size = 100000

0 commit comments

Comments
 (0)