update commit configuration on workers

Author: rberrelleza

worker/cmd/worker/main.go

@@ -42,13 +42,13 @@ func main() {
 	defer master.Close()
 
 	// Consumer for "rentals" topic
-	consumerRentals, err := master.ConsumePartition("rentals", 0, sarama.OffsetOldest)
+	consumerRentals, err := master.ConsumePartition("rentals", 0, sarama.OffsetNewest)
 	if err != nil {
 		log.Panic(err)
 	}
 
 	// Consumer for "returns" topic
-	consumerReturns, err := master.ConsumePartition("returns", 0, sarama.OffsetOldest)
+	consumerReturns, err := master.ConsumePartition("returns", 0, sarama.OffsetNewest)
 	if err != nil {
 		log.Panic(err)
 	}

worker/pkg/kafka/kafka.go

@@ -2,6 +2,7 @@ package kafka
 
 import (
 	"fmt"
+	"time"
 
 	kingpin "gopkg.in/alecthomas/kingpin.v2"
 
@@ -16,6 +17,8 @@ func GetMaster() sarama.Consumer {
 	kingpin.Parse()
 	config := sarama.NewConfig()
 	config.Consumer.Return.Errors = true
+	config.Consumer.Offsets.AutoCommit.Enable = true
+	config.Consumer.Offsets.AutoCommit.Interval = 1 * time.Second
 	brokers := *brokerList
 	fmt.Println("Waiting for kafka...")
 	for {