fix: change Kafka poll to block for 100ms instead of 100ns when no ev…

…ents
topfreegames · Dec 17, 2024 · be8520b · be8520b
1 parent c749415
commit be8520b
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/feedback/kafka_consumer.go b/feedback/kafka_consumer.go
@@ -25,6 +25,7 @@ package feedback
 import (
 	"context"
 	"sync"
+	"time"
 
 	"github.com/confluentinc/confluent-kafka-go/v2/kafka"
 	"github.com/getsentry/raven-go"
@@ -211,7 +212,7 @@ func (q *KafkaConsumer) ConsumeLoop(ctx context.Context) error {
 			l.Info("context done, stopping consuming")
 			return nil
 		default:
-			message, err := q.Consumer.ReadMessage(100)
+			message, err := q.Consumer.ReadMessage(100 * time.Millisecond)
 			if message == nil && err.(kafka.Error).IsTimeout() {
 				continue
 			}