closing after one message consumer

port-labs · Dec 20, 2023 · 06451f1 · 06451f1
1 parent ae6ccad
commit 06451f1
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/event_handler/consumer/consumer_test.go b/pkg/event_handler/consumer/consumer_test.go
@@ -37,6 +37,7 @@ func (m *MockConsumer) SubscribeTopics(topics []string, rebalanceCb kafka.Rebala
 }
 
 func (m *MockConsumer) Poll(timeoutMs int) (event kafka.Event) {
+	// The consumer will poll this in while true loop so we need to close it inorder not to spam the logs
 	defer func() {
 		m.close()
 	}()