Method ConsumeClaim

consumer_group.go:1247–1247

ConsumeClaim must start a consumer loop of ConsumerGroupClaim's Messages(). Once the Messages() channel is closed, the Handler must finish its processing loop and exit. Handlers should also return when ConsumerGroupSession.Context() is done; Messages() alone can block while the partition consumer is

(ConsumerGroupSession, ConsumerGroupClaim)

	// is done; Messages() alone can block while the partition consumer is retrying
	// (e.g. after a broker disconnect). See examples/consumergroup.
	ConsumeClaim(ConsumerGroupSession, ConsumerGroupClaim) error
}

// ConsumerGroupClaim processes Kafka messages from a given topic and partition within a consumer group.