(metadataVersion apiVersion, size int)
| 998 | } |
| 999 | |
| 1000 | func (c *Conn) readPartitionsResponse(metadataVersion apiVersion, size int) ([]Partition, error) { |
| 1001 | switch metadataVersion { |
| 1002 | case v6: |
| 1003 | var res metadataResponseV6 |
| 1004 | if err := c.readResponse(size, &res); err != nil { |
| 1005 | return nil, err |
| 1006 | } |
| 1007 | brokers := readBrokerMetadata(res.Brokers) |
| 1008 | return c.readTopicMetadatav6(brokers, res.Topics) |
| 1009 | default: |
| 1010 | var res metadataResponseV1 |
| 1011 | if err := c.readResponse(size, &res); err != nil { |
| 1012 | return nil, err |
| 1013 | } |
| 1014 | brokers := readBrokerMetadata(res.Brokers) |
| 1015 | return c.readTopicMetadatav1(brokers, res.Topics) |
| 1016 | } |
| 1017 | } |
| 1018 | |
| 1019 | func readBrokerMetadata(brokerMetadata []brokerMetadataV1) map[int32]Broker { |
| 1020 | brokers := make(map[int32]Broker, len(brokerMetadata)) |
no test coverage detected