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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
