when i use demo of consumergroup got panic err

[pengtianyue025]

Versions

Please specify real version numbers or git SHAs, not just "Latest" since that changes fairly regularly.

Sarama	Kafka	Go
1.33	2.12-2.3.1	go16

Configuration

What configuration values are you using for Sarama and Kafka?

func (consumer *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error {
	// NOTE:
	// Do not move the code below to a goroutine.
	// The `ConsumeClaim` itself is called within a goroutine, see:
	// https://github.com/Shopify/sarama/blob/main/consumer_group.go#L27-L29
	for {
		select {
		case message := <-claim.Messages():
			log.Printf("Message claimed: value = %s, timestamp = %v, topic = %s", string(message.Value), message.Timestamp, message.Topic)
			session.MarkMessage(message, "")

		// Should return when `session.Context()` is done.
		// If not, will raise `ErrRebalanceInProgress` or `read tcp <ip>:<port>: i/o timeout` when kafka rebalance. see:
		// https://github.com/Shopify/sarama/issues/1192
		case <-session.Context().Done():
			return nil
		}
	}
}

Logs

panic: runtime error: invalid memory address or nil pointer dereference
[signal SIGSEGV: segmentation violation code=0x1 addr=0x60 pc=0x1016b77]

goroutine 307 [running]:
base.(*Consumer).ConsumeClaim(0xc0000c7290, 0x1714c28, 0xc000129500, 0x170cf78, 0xc002d8b7a0, 0xc, 0x1)
kafka.go:95 +0x1b7 # panic at log.Printf（same with demo）

Problem Description

this code may got nil with message? and then print cause panic

case message := <-claim.Messages():

[buddy-yao]

Same problem, any solutions?

[pengtianyue025]

When i got a nil message， i just continue( maybe the consumer is close, just return is ok?).

[dnwe]

Sorry for the delay, this was fixed by #2479