Method useConsumerGroup

reader.go:97–97

useConsumerGroup indicates whether the Reader is part of a consumer group.

()

// useConsumerGroup indicates whether the Reader is part of a consumer group.
func (r *Reader) useConsumerGroup() bool { return r.config.GroupID != "" }

func (r *Reader) getTopics() []string {
	if len(r.config.GroupTopics) > 0 {