Method Consume

consumer_group.go:61–61

Consume joins a cluster of consumers for a given list of topics and starts a blocking ConsumerGroupSession through the ConsumerGroupHandler. The life-cycle of a session is represented by the following steps: 1. The consumers join the group (as explained in https://kafka.apache.org/documentation/#i

(ctx context.Context, topics []string, handler ConsumerGroupHandler)

	// server-side rebalance happens, the consumer session will need to be
	// recreated to get the new claims.
	Consume(ctx context.Context, topics []string, handler ConsumerGroupHandler) error

	// Errors returns a read channel of errors that occurred during the consumer life-cycle.
	// By default, errors are logged and not returned over this channel.