In the documentation
<https://pulsar.apache.org/docs/en/next/concepts-clients/> there is an
admonition:
Non-partitioned topics only
The reader interface for Pulsar cannot currently be used withpartitioned
topics
<https://pulsar.apache.org/docs/en/next/concepts-messaging#partitioned-topics>.
Is this still true? I notice in ReaderImpl.Java
* final int partitionIdx =
TopicName.getPartitionIndex(readerConfiguration.getTopicName());**
* consumer = new ConsumerImpl<>(client,
readerConfiguration.getTopicName(), consumerConfiguration,
listenerExecutor, *partitionIdx*, false,
consumerFuture, SubscriptionMode.NonDurable,
readerConfiguration.getStartMessageId(),
readerConfiguration.getStartMessageFromRollbackDurationInSec(),
schema, null, true /* createTopicIfDoesNotExist */);
Thanks,
Brian.