Topics returns the set of available topics as retrieved from cluster metadata.
()
| 43 | |
| 44 | // Topics returns the set of available topics as retrieved from cluster metadata. |
| 45 | Topics() ([]string, error) |
| 46 | |
| 47 | // Partitions returns the sorted list of all partition IDs for the given topic. |
| 48 | Partitions(topic string) ([]int32, error) |
no outgoing calls