diff options
Diffstat (limited to 'kafka/producer/sender.py')
| -rw-r--r-- | kafka/producer/sender.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/kafka/producer/sender.py b/kafka/producer/sender.py index 88ec07c..705b58f 100644 --- a/kafka/producer/sender.py +++ b/kafka/producer/sender.py @@ -315,6 +315,9 @@ class Sender(threading.Thread): """Wake up the selector associated with this send thread.""" self._client.wakeup() + def bootstrap_connected(self): + return self._client.bootstrap_connected() + class SenderMetrics(object): |