You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2022/04/10 13:11:12 UTC
[GitHub] [pulsar] zbentley commented on issue #15078: [2.9.1] Python client returns UnknownError in some cases when it should return a specific error class
zbentley commented on issue #15078:
URL: https://github.com/apache/pulsar/issues/15078#issuecomment-1094272476
I can reproduce with that exact snippet, substituting only my topic name.
The topic is:
- Persistent
- Partitioned
- Has two subscriptions, both behind
- Does not have any consumers active
- Uses BytesSchema
- Is the only topic in its namespace
- Does not have compaction or dedup enabled.
When I run the above snippet with my topic name and a backlog that's over quota I get:
```
2022-04-10 09:07:03.039 INFO [0x105619600] ClientConnection:181 | [<none> -> pulsar://localhost:6650] Create ClientConnection, timeout=10000
2022-04-10 09:07:03.039 INFO [0x105619600] ConnectionPool:96 | Created connection for pulsar://localhost:6650
2022-04-10 09:07:03.041 INFO [0x70000451e000] ClientConnection:367 | [127.0.0.1:52487 -> 127.0.0.1:6650] Connected to broker
2022-04-10 09:07:03.043 INFO [0x70000451e000] HandlerBase:64 | [persistent://chariot1/chariot_namespace_heartbeat/chariot_topic_heartbeat-partition-0, ] Getting connection from pool
2022-04-10 09:07:03.043 INFO [0x70000451e000] HandlerBase:64 | [persistent://chariot1/chariot_namespace_heartbeat/chariot_topic_heartbeat-partition-1, ] Getting connection from pool
2022-04-10 09:07:03.043 INFO [0x70000451e000] HandlerBase:64 | [persistent://chariot1/chariot_namespace_heartbeat/chariot_topic_heartbeat-partition-2, ] Getting connection from pool
2022-04-10 09:07:03.043 INFO [0x70000451e000] HandlerBase:64 | [persistent://chariot1/chariot_namespace_heartbeat/chariot_topic_heartbeat-partition-3, ] Getting connection from pool
2022-04-10 09:07:03.045 WARN [0x70000451e000] ClientConnection:1052 | [127.0.0.1:52487 -> 127.0.0.1:6650] Received error response from server: ProducerBlockedQuotaExceededException (Cannot create producer on topic with backlog quota exceeded) -- req_id: 0
2022-04-10 09:07:03.045 ERROR [0x70000451e000] ProducerImpl:248 | [persistent://chariot1/chariot_namespace_heartbeat/chariot_topic_heartbeat-partition-0, ] Failed to create producer: ProducerBlockedQuotaExceededException
2022-04-10 09:07:03.045 INFO [0x70000451e000] ProducerImpl:621 | [persistent://chariot1/chariot_namespace_heartbeat/chariot_topic_heartbeat-partition-0, ] Closing producer for topic persistent://chariot1/chariot_namespace_heartbeat/chariot_topic_heartbeat-partition-0
2022-04-10 09:07:03.045 INFO [0x70000451e000] ProducerImpl:621 | [persistent://chariot1/chariot_namespace_heartbeat/chariot_topic_heartbeat-partition-1, ] Closing producer for topic persistent://chariot1/chariot_namespace_heartbeat/chariot_topic_heartbeat-partition-1
2022-04-10 09:07:03.045 INFO [0x70000451e000] ProducerImpl:621 | [persistent://chariot1/chariot_namespace_heartbeat/chariot_topic_heartbeat-partition-2, ] Closing producer for topic persistent://chariot1/chariot_namespace_heartbeat/chariot_topic_heartbeat-partition-2
2022-04-10 09:07:03.045 INFO [0x70000451e000] ProducerImpl:621 | [persistent://chariot1/chariot_namespace_heartbeat/chariot_topic_heartbeat-partition-3, ] Closing producer for topic persistent://chariot1/chariot_namespace_heartbeat/chariot_topic_heartbeat-partition-3
2022-04-10 09:07:03.045 ERROR [0x70000451e000] PartitionedProducerImpl:152 | Unable to create Producer for partition - 0 Error - ProducerBlockedQuotaExceededException
Traceback (most recent call last):
File "scratch.py", line 8, in <module>
2022-04-10 09:07:03.045 WARN [0x70000451e000] ClientConnection:1052 | [127.0.0.1:52487 -> 127.0.0.1:6650] Received error response from server: ProducerBlockedQuotaExceededException (Cannot create producer on topic with backlog quota exceeded) -- req_id: 1
producer = client.create_producer('persistent://chariot1/chariot_namespace_heartbeat/chariot_topic_heartbeat')
File "/Users/zac.bentley/Desktop/Projects/Klaviyo/chariot/.venv/lib/python3.7/site-packages/pulsar/__init__.py", line 603, in create_producer
2022-04-10 09:07:03.045 WARN [0x70000451e000] ClientConnection:1052 | [127.0.0.1:52487 -> 127.0.0.1:6650] Received error response from server: ProducerBlockedQuotaExceededException (Cannot create producer on topic with backlog quota exceeded) -- req_id: 2
p._producer = self._client.create_producer(topic, conf)
_pulsar.UnknownError: Pulsar error: UnknownError
2022-04-10 09:07:03.046 WARN [0x70000451e000] ClientConnection:1052 | [127.0.0.1:52487 -> 127.0.0.1:6650] Received error response from server: ProducerBlockedQuotaExceededException (Cannot create producer on topic with backlog quota exceeded) -- req_id: 3
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org