|
@@ -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:
|