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/07 22:31:06 UTC

[GitHub] [pulsar] zbentley opened a new issue, #15078: [2.9.1] Python client returns UnknownError in some cases when it should return a specific error class

zbentley opened a new issue, #15078:
URL: https://github.com/apache/pulsar/issues/15078

**Describe the bug**
The Python client raises `_pulsar.UnknownError: Pulsar error: UnknownError` in cases when client logs indicate a specific exception code (for which there is already a specific error subclass) was recieved.

**To Reproduce**
0. Create a Client object with a Python logger that emits at INFO and above (e.g. `logging.getLogger()`).
1. Create a persistent topic with a backlog policy that is very "short", e.g. 1mb.
2. With a Python producer, send messages to the topic continually until the backlog quota is hit.
3. Observe that the Python producer errors with an UnknownError rather than ProducerBlockedQuotaExceededException.
4. Observe that the client logs show the arrival of a ProducerBlockedQuotaExceededException event.
5. Attempt to re-create the producer on the quota-blocked topic.
6. Observe that the same issue occurs: logs indicate ProducerBlockedQuotaExceededException, but an UnknownError is raised.

**Expected behavior**
Specific error classes (the exception classes distributed in the pulsar-client package) should be raised instead of UnknownError when the client can match an error event (visible in the logs) to an exception class: ProducerBlockedQuotaExceededException

I suspect the issue is with the boost-python mapping code; I don't think class-type checks are matching correctly on C++ exception objects.

**Example logs**:
```
chariot.chariot.pulsar_client::75192::Dummy-8::WARNING 2022-04-07 18:06:35,902 [127.0.0.1:58048 -> 127.0.0.1:6650] Received error response from server: ProducerBlockedQuotaExceededException (Cannot create producer on topic with backlog quota exceeded) -- req_id: 0
chariot.chariot.pulsar_client::75192::Dummy-8::ERROR 2022-04-07 18:06:35,902 [persistent://chariot1/chariot_namespace_heartbeat/chariot_topic_heartbeat-partition-0, SynchronousChariotProducer-heartbeat-1-ZacBentleyMBP-75192] Failed to create producer: ProducerBlockedQuotaExceededException
chariot.chariot.pulsar_client::75192::Dummy-8::ERROR 2022-04-07 18:06:35,902 Unable to create Producer for partition - 0 Error - ProducerBlockedQuotaExceededException
```

**Example stacktrace which accompanies those logs:**
```
Traceback (most recent call last):
File "/Users/zac.bentley/Desktop/Projects/Klaviyo/chariot/.venv/lib/python3.7/site-packages/pulsar/__init__.py", line 603, in create_producer
p._producer = self._client.create_producer(topic, conf)
_pulsar.UnknownError: Pulsar error: UnknownError
```

--
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.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org