diff options
Diffstat (limited to 'kafka/client.py')
| -rw-r--r-- | kafka/client.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/client.py b/kafka/client.py index 8630f66..89664fc 100644 --- a/kafka/client.py +++ b/kafka/client.py @@ -81,7 +81,7 @@ class KafkaClient(object): """ Generate a new correlation id """ - return KafkaClient.ID_GEN.next() + return next(KafkaClient.ID_GEN) def _send_broker_unaware_request(self, requestId, request): """ |