| 92 | } |
| 93 | |
| 94 | type consumerGroup struct { |
| 95 | client Client |
| 96 | |
| 97 | config *Config |
| 98 | consumer Consumer |
| 99 | groupID string |
| 100 | groupInstanceId *string |
| 101 | memberID string |
| 102 | lastSessionCause error |
| 103 | errors chan error |
| 104 | |
| 105 | lock sync.Mutex |
| 106 | errorsLock sync.RWMutex |
| 107 | closed chan none |
| 108 | closeOnce sync.Once |
| 109 | |
| 110 | userData []byte |
| 111 | |
| 112 | metricRegistry metrics.Registry |
| 113 | } |
| 114 | |
| 115 | // NewConsumerGroup creates a new consumer group the given broker addresses and configuration. |
| 116 | func NewConsumerGroup(addrs []string, groupID string, config *Config) (ConsumerGroup, error) { |
nothing calls this directly
no outgoing calls
no test coverage detected