Method Messages

consumer_group.go:1271–1271

Messages returns the read channel for the messages that are returned by the broker. The messages channel will be closed when a new rebalance cycle is due. You must finish processing and mark offsets within Config.Consumer.Group.Session.Timeout before the topic/partition is eventually re-assigned to

()

	// Config.Consumer.Group.Session.Timeout before the topic/partition is eventually
	// re-assigned to another group member.
	Messages() <-chan *ConsumerMessage
}

type consumerGroupClaim struct {