Consumer

- fix

consumer/consumer.go

@@ -44,7 +44,6 @@ func New(cfg *Config) (service.Consumer, error) {
 		"partition.assignment.strategy": "cooperative-sticky",
 		"auto.offset.reset":             "earliest",
 		"log_level":                     0,
-		"enable.auto.commit":            false,
 	}
 
 	if c.session, err = kafka.NewConsumer(opts); err != nil {