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.

Reply via email to