openstack/oslo.messaging
Code Issues Proposed changes

Merge "kafka: timeout is in milliseconds"

Browse Source
This commit is contained in:
Jenkins 2017-01-04 13:11:29 +00:00 committed by Gerrit Code Review
commit 8ac9558c6e
1 changed files with 1 additions and 1 deletions

2
oslo_messaging/_drivers/impl_kafka.py

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