On 04/11/2019 16:34, Matteo Merli wrote:
The documentation is correct in that a reader can only "read" a
non-partitioned topic or one specific partition of a topic.

To get a list of the partitions, you can use
`PulsarClient.getPartitionsForTopic()` and then create a reader for
each partitions.

Thanks.  So I suggest replacing:

"The reader interface for Pulsar cannot currently be used with partitioned topics."

with something like:

"When using the reader interface with a partitioned topic, a separate reader instance is required for each partition"


Reply via email to