From c8880b6f11ec8ad7ac9a72fcc1285110ce5e0000 Mon Sep 17 00:00:00 2001
From: Mehdi Abaakouk <sileht@redhat.com>
Date: Thu, 8 Dec 2016 10:52:41 +0100
Subject: [PATCH] kafka: timeout is in milliseconds

Change-Id: I791c5dd8e7f4fb46a0aea3e825b9b392686a2abd
---
 oslo_messaging/_drivers/impl_kafka.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/oslo_messaging/_drivers/impl_kafka.py b/oslo_messaging/_drivers/impl_kafka.py
index 4c8dc29c7..43e0cec5d 100644
--- a/oslo_messaging/_drivers/impl_kafka.py
+++ b/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.