python pulsar-clinet create_reader causes "OperationNotSupported" exception

[kyky19831214]

the pulsar-client version is 2.9.2,
using the same parameter , consumer is ok but reader throws exception when I create them.
I change to java creating "reader", that is ok, I don`t know why python not work.
for help.

2022-09-23 22:47:01.912 INFO  [0x17146f000] ConsumerImpl:222 | [persistent://autopilot-operation-platform/x01/autopilot-operation-platform-filter-iot-signal-canlog-x01-testtwo-partition-4, zs5, 4] Created consumer on broker [10.240.192.211:57906 -> 172.21.206.57:6650] 
2022-09-23 22:47:01.912 INFO  [0x17146f000] ConsumerImpl:222 | [persistent://autopilot-operation-platform/x01/autopilot-operation-platform-filter-iot-signal-canlog-x01-testtwo-partition-0, zs5, 0] Created consumer on broker [10.240.192.211:57906 -> 172.21.206.57:6650] 
2022-09-23 22:47:01.912 INFO  [0x17146f000] PartitionedConsumerImpl:301 | Successfully Subscribed to Partitioned Topic - persistent://autopilot-operation-platform/x01/autopilot-operation-platform-filter-iot-signal-canlog-x01-testtwo with - 6 Partitions.
2022-09-23 22:47:02.019 ERROR [0x17146f000] ClientImpl:231 | Topic reader cannot be created on a partitioned topic: persistent://autopilot-operation-platform/x01/autopilot-operation-platform-filter-iot-signal-canlog-x01-testtwo
Traceback (most recent call last):
  File "<input>", line 1, in <module>
  File "/Applications/PyCharm.app/Contents/plugins/python/helpers/pydev/_pydev_bundle/pydev_umd.py", line 198, in runfile
    pydev_imports.execfile(filename, global_vars, local_vars)  # execute the script
  File "/Applications/PyCharm.app/Contents/plugins/python/helpers/pydev/_pydev_imps/_pydev_execfile.py", line 18, in execfile
    exec(compile(contents+"\n", file, 'exec'), glob, loc)
  File "/Users/XXX/Library/Application Support/JetBrains/PyCharm2021.2/scratches/pulsar/client_lixiang_test.py", line 15, in <module>
    reader = client.create_reader(topic, MessageId.earliest)
  File "/Users/XXX/Library/Python/3.10/lib/python/site-packages/pulsar/__init__.py", line 847, in create_reader
    c._reader = self._client.create_reader(topic, start_message_id, conf)
_pulsar.OperationNotSupported: Pulsar error: OperationNotSupported

serviceUrl = "XXX"
adminUrl = "XXX"
topic = "XXX"
token = "XXX"
subScripName = 'zs5'

client = Client(serviceUrl, authentication=AuthenticationToken(token))
consumer = client.subscribe(topic, subScripName)

reader = client.create_reader(topic, MessageId.earliest)

[shibd]

I will look at it.

[shibd]

@kyky19831214 Hi, Can you provide your reproduce code?

[michaeljmarshall]

@kyky19831214 - would you consider editing your question so that it has text instead of screen shots? Text is much easier to find when searching for results with search engines. Thanks!

[kyky19831214]

It has been added.

[merlimat]

@kyky19831214 You're creating a reader over a partitioned topic. You should create the reader on the individual partitions instead.

You can get the list of partitions using client.get_topic_partitions(): https://pulsar.apache.org/api/python/2.10.1/pulsar.html#Client.get_topic_partitions

[kyky19831214]

thank you very much.
I solved this problem.
according your advice, I change the topic to ' individual partitions', the reader object is created successfully.