(child *partitionConsumer)
| 239 | } |
| 240 | |
| 241 | func (c *consumer) removeChild(child *partitionConsumer) { |
| 242 | c.lock.Lock() |
| 243 | defer c.lock.Unlock() |
| 244 | |
| 245 | delete(c.children[child.topic], child.partition) |
| 246 | } |
| 247 | |
| 248 | func (c *consumer) refBrokerConsumer(broker *Broker) *brokerConsumer { |
| 249 | c.lock.Lock() |