Explorar o código

fix error message s/CommitInterval/AutoCommit.Interval

Diego Alvarez %!s(int64=6) %!d(string=hai) anos
pai
achega
052b8500ca
Modificáronse 1 ficheiros con 1 adicións e 1 borrados
  1. 1 1
      config.go

+ 1 - 1
config.go

@@ -679,7 +679,7 @@ func (c *Config) Validate() error {
 	case c.Consumer.Retry.Backoff < 0:
 		return ConfigurationError("Consumer.Retry.Backoff must be >= 0")
 	case c.Consumer.Offsets.AutoCommit.Interval <= 0:
-		return ConfigurationError("Consumer.Offsets.CommitInterval must be > 0")
+		return ConfigurationError("Consumer.Offsets.AutoCommit.Interval must be > 0")
 	case c.Consumer.Offsets.Initial != OffsetOldest && c.Consumer.Offsets.Initial != OffsetNewest:
 		return ConfigurationError("Consumer.Offsets.Initial must be OffsetOldest or OffsetNewest")
 	case c.Consumer.Offsets.Retry.Max < 0: