max.poll.interval.ms must be >= 30s

YenchangChan · YenchangChan · commit ded59cb36a20 · 2025-05-06T09:11:51.000+08:00
diff --git a/config/config.go b/config/config.go
@@ -318,6 +318,9 @@ func (cfg *Config) Normallize(constructGroup bool, httpAddr string, cred util.Cr
 	if cfg.Kafka.Properties.MaxPollInterval == 0 {
 		cfg.Kafka.Properties.MaxPollInterval = DefaultMaxPollIntervalMs
 	}
+	if cfg.Kafka.Properties.MaxPollInterval < 30000 {
+		cfg.Kafka.Properties.MaxPollInterval = 30000
+	}
 	if cfg.Kafka.AssignInterval == 0 {
 		cfg.Kafka.AssignInterval = defaultAssignIntervalMin
 	}

Original file line number	Diff line number	Diff line change
`@@ -318,6 +318,9 @@ func (cfg *Config) Normallize(constructGroup bool, httpAddr string, cred util.Cr`
`318`	`318`	`if cfg.Kafka.Properties.MaxPollInterval == 0 {`
`319`	`319`	`cfg.Kafka.Properties.MaxPollInterval = DefaultMaxPollIntervalMs`
`320`	`320`	`}`
	`321`	`+ if cfg.Kafka.Properties.MaxPollInterval < 30000 {`
	`322`	`+ cfg.Kafka.Properties.MaxPollInterval = 30000`
	`323`	`+ }`
`321`	`324`	`if cfg.Kafka.AssignInterval == 0 {`
`322`	`325`	`cfg.Kafka.AssignInterval = defaultAssignIntervalMin`
`323`	`326`	`}`