openstack/oslo.messaging
Code Issues Proposed changes

Fix type of the kafka_consumer_timeout option

Browse Source 
Change-Id: Ibe7a72cef031e84221522183521f65c238a2d8e5
This commit is contained in:
Pierre Riteau 2017-01-31 12:09:23 +00:00
parent 337f499c58
commit aab5ea2dfd
2 changed files with 3 additions and 3 deletions
oslo_messaging/_drivers
impl_kafka.pykafka_options.py

2
oslo_messaging/_drivers/impl_kafka.py

@ -124,7 +124,7 @@ class Connection(object):
self.producer = None
self.producer_lock = threading.Lock()
self.consumer = None
self.consumer_timeout = float(driver_conf.kafka_consumer_timeout)
self.consumer_timeout = driver_conf.kafka_consumer_timeout
self.max_fetch_bytes = driver_conf.kafka_max_fetch_bytes
self.group_id = driver_conf.consumer_group
self.url = url

4
oslo_messaging/_drivers/kafka_options.py

@ -27,8 +27,8 @@ KAFKA_OPTS = [
cfg.IntOpt('kafka_max_fetch_bytes', default=1024 * 1024,
help='Max fetch bytes of Kafka consumer'),
cfg.IntOpt('kafka_consumer_timeout', default=1.0,
help='Default timeout(s) for Kafka consumers'),
cfg.FloatOpt('kafka_consumer_timeout', default=1.0,
help='Default timeout(s) for Kafka consumers'),
cfg.IntOpt('pool_size', default=10,
help='Pool Size for Kafka Consumers'),