(consumerGroup string)
| 620 | } |
| 621 | |
| 622 | func (client *client) RefreshCoordinator(consumerGroup string) error { |
| 623 | if client.Closed() { |
| 624 | return ErrClosedClient |
| 625 | } |
| 626 | |
| 627 | response, err := client.findCoordinator(consumerGroup, CoordinatorGroup, client.conf.Metadata.Retry.Max) |
| 628 | if err != nil { |
| 629 | return err |
| 630 | } |
| 631 | |
| 632 | client.lock.Lock() |
| 633 | defer client.lock.Unlock() |
| 634 | client.registerBroker(response.Coordinator) |
| 635 | client.coordinators[consumerGroup] = response.Coordinator.ID() |
| 636 | return nil |
| 637 | } |
| 638 | |
| 639 | func (client *client) TransactionCoordinator(transactionID string) (*Broker, error) { |
| 640 | if client.Closed() { |
no test coverage detected