We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1c21959 commit a866d99Copy full SHA for a866d99
kafka/conn.py
@@ -1100,7 +1100,8 @@ def _maybe_throttle(self, response):
1100
if not self.config['api_version'] or self.config['api_version'] >= (2, 0):
1101
throttle_time = time.time() + throttle_time_ms / 1000
1102
self._throttle_time = max(throttle_time, self._throttle_time or 0)
1103
- log.warning("%s throttled by broker (%d ms)", response.__name__, throttle_time_ms)
+ log.warning("%s: %s throttled by broker (%d ms)", self,
1104
+ response.__class__.__name__, throttle_time_ms)
1105
1106
def can_send_more(self):
1107
"""Check for throttling / quota violations and max in-flight-requests"""
0 commit comments