feat: change the default consumer session timeout to 30 seconds (#105)

honestbank · Oct 10, 2024 · 283ac99 · 283ac99
1 parent 9c742d7
commit 283ac99
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/v2/config/config.go b/v2/config/config.go
@@ -28,7 +28,7 @@ func (s Kafka) WithDefaults() Kafka {
 		SecurityProtocol:         s.SecurityProtocol,
 		Username:                 s.Username,
 		Password:                 s.Password,
-		ConsumerSessionTimeoutMs: defaultIfNil(s.ConsumerSessionTimeoutMs, 6000),
+		ConsumerSessionTimeoutMs: defaultIfNil(s.ConsumerSessionTimeoutMs, 30000),
 		ConsumerAutoOffsetReset:  defaultIfNil(s.ConsumerAutoOffsetReset, "earliest"),
 		ClientID:                 defaultIfNil(s.ClientID, "rdkafka"),
 		Debug:                    s.Debug,