(topics ...string)
| 635 | } |
| 636 | |
| 637 | func (t *timeoutCoordinator) readPartitions(topics ...string) ([]Partition, error) { |
| 638 | if err := t.conn.SetDeadline(time.Now().Add(t.timeout)); err != nil { |
| 639 | return nil, err |
| 640 | } |
| 641 | return t.conn.ReadPartitions(topics...) |
| 642 | } |
| 643 | |
| 644 | // NewConsumerGroup creates a new ConsumerGroup. It returns an error if the |
| 645 | // provided configuration is invalid. It does not attempt to connect to the |
nothing calls this directly
no test coverage detected