Remove max wait (so now 10s)

emortalmc · Jun 28, 2023 · bd57be2 · bd57be2
1 parent cfb7217
commit bd57be2
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/internal/kafka/consumer.go b/internal/kafka/consumer.go
@@ -18,7 +18,6 @@ import (
 	"mc-player-service/internal/repository/model"
 	"mc-player-service/internal/utils"
 	"sync"
-	"time"
 )
 
 const connectionsTopic = "mc-connections"
@@ -48,8 +47,6 @@ func NewConsumer(ctx context.Context, wg *sync.WaitGroup, config *config.KafkaCo
 		ErrorLogger: kafka.LoggerFunc(func(format string, args ...interface{}) {
 			logger.Errorw(fmt.Sprintf(format, args...))
 		}),
-
-		MaxWait: 5 * time.Second,
 	})
 
 	c := &consumer{