>From the code snippet, it seems that the description in the document is obsolete. If so, we can update the doc accordingly. Could any eng confirm the issue?
Best Regards, Jennifer On Sun, Nov 3, 2019 at 4:51 PM Brian Candler <b.cand...@pobox.com> wrote: > 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 with partitioned > 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. >
