()
| 97 | func (r *Reader) useConsumerGroup() bool { return r.config.GroupID != "" } |
| 98 | |
| 99 | func (r *Reader) getTopics() []string { |
| 100 | if len(r.config.GroupTopics) > 0 { |
| 101 | return r.config.GroupTopics[:] |
| 102 | } |
| 103 | |
| 104 | return []string{r.config.Topic} |
| 105 | } |
| 106 | |
| 107 | // useSyncCommits indicates whether the Reader is configured to perform sync or |
| 108 | // async commits. |