openstack/oslo.messaging
Code Issues Proposed changes

kafka: timeout is in milliseconds

Browse Source 
Change-Id: I791c5dd8e7f4fb46a0aea3e825b9b392686a2abd
This commit is contained in:
Mehdi Abaakouk 2016-12-08 10:52:41 +01:00
parent 799cd6fa8f
commit c8880b6f11
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
oslo_messaging/_drivers/impl_kafka.py
View File

@ -181,7 +181,7 @@ class Connection(object):
@with_reconnect() @with_reconnect()
def _poll_messages(self, timeout): def _poll_messages(self, timeout):
return self.consumer.poll(timeout) return self.consumer.poll(timeout * 1000.0)
def consume(self, timeout=None): def consume(self, timeout=None):
"""Receive up to 'max_fetch_messages' messages. """Receive up to 'max_fetch_messages' messages.