Partitions returns the sorted list of all partition IDs for the given topic. This method is the same as Client.Partitions(), and is provided for convenience.
(topic string)
| 60 | // Partitions returns the sorted list of all partition IDs for the given topic. |
| 61 | // This method is the same as Client.Partitions(), and is provided for convenience. |
| 62 | Partitions(topic string) ([]int32, error) |
| 63 | |
| 64 | // ConsumePartition creates a PartitionConsumer on the given topic/partition with |
| 65 | // the given offset. It will return an error if this Consumer is already consuming |