claim.Messages() seems returning nil sometime, avoid nil pointer (#865)

claim.Messages() seems returning nil sometime, avoid nil pointer Signed-off-by: nbajaj90 <nbajaj90@gmail.com>
cloudevents · Mar 15, 2023 · 581f868 · 581f868
1 parent e9e303c
commit 581f868
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/protocol/kafka_sarama/v2/receiver.go b/protocol/kafka_sarama/v2/receiver.go
@@ -62,7 +62,10 @@ func (r *Receiver) ConsumeClaim(session sarama.ConsumerGroupSession, claim saram
 	// https://github.com/Shopify/sarama/blob/main/consumer_group.go#L27-L29
 	for {
 		select {
-		case msg := <-claim.Messages():
+		case msg, ok := <-claim.Messages():
+			if !ok {
+				return nil
+			}
 			m := NewMessageFromConsumerMessage(msg)
 
 			r.incoming <- msgErr{