Merge #6

6: Bump deps, set default consumer offset to "oldest" r=Jaskaranbir a=Jaskaranbir Co-authored-by: Jaskaranbir <jaskaranbir.dhillon@gmail.com>
TerrexTech · Sep 9, 2018 · e269211 · e269211
2 parents ef511c3 + 719035e
commit e269211
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 11 deletions.
diff --git a/Gopkg.lock b/Gopkg.lock
diff --git a/consumer/consumer.go b/consumer/consumer.go
@@ -67,7 +67,7 @@ func New(initConfig *Config) (*Consumer, error) {
 		config = initConfig.SaramaConfig
 	} else {
 		config = cluster.NewConfig()
-		config.Consumer.Offsets.Initial = sarama.OffsetNewest
+		config.Consumer.Offsets.Initial = sarama.OffsetOldest
 		config.Consumer.MaxProcessingTime = 10 * time.Second
 		config.Consumer.Return.Errors = true
 	}