You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@pulsar.apache.org by GitBox <gi...@apache.org> on 2022/09/23 14:56:52 UTC
[GitHub] [pulsar] kyky19831214 edited a discussion: python pulsar-clinet create_reader causes "OperationNotSupported" exception
GitHub user kyky19831214 edited a discussion: python pulsar-clinet create_reader causes "OperationNotSupported" exception
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)
GitHub link: https://github.com/apache/pulsar/discussions/17800
----
This is an automatically sent email for dev@pulsar.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@pulsar.apache.org