I didn't find anything in the documentation related to reading from all partitions of a topic, just from a specific partition. Is it possible to read from all partitions? How to do this?
// get a partition-bound client
let partition_client = client
.partition_client(
topic.to_owned(),
0, // partition
UnknownTopicHandling::Retry,
)
.await
.unwrap();