search

bsm / sarama-cluster

Cluster extensions for Sarama, the Go client library for Apache Kafka 0.9 [DEPRECATED]
MIT License
1.01k stars 222 forks source link

Offsets.CommitInterval has change to Offsets.AutoCommit.Interval #304

Closed kira3007 closed 5 years ago

kira3007 commented 5 years ago

github.com/bsm/sarama-cluster

src/github.com/bsm/sarama-cluster/consumer.go:452:59: c.client.config.Config.Consumer.Offsets.CommitInterval undefined (type struct { AutoCommit struct { Enable bool; Interval time.Duration }; Initial int64; Retention time.Duration; Retry struct { Max int } } has no field or method CommitInterval)

in sarama-cluster/consumer.go line 452 :

ticker := time.NewTicker(c.client.config.Consumer.Offsets.AutoCommit.Interval)

dim commented 5 years ago

Please note https://github.com/bsm/sarama-cluster#deprecation-notice