openstack/oslo.messaging
Code Issues Proposed changes

Merge "Fix type of the kafka_consumer_timeout option"

Browse Source
This commit is contained in:
Jenkins 2017-02-15 12:39:35 +00:00 committed by Gerrit Code Review
commit 07486845eb
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 = None
self.producer_lock = threading.Lock() self.producer_lock = threading.Lock()
self.consumer = None 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.max_fetch_bytes = driver_conf.kafka_max_fetch_bytes
self.group_id = driver_conf.consumer_group self.group_id = driver_conf.consumer_group
self.url = url 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, cfg.IntOpt('kafka_max_fetch_bytes', default=1024 * 1024,
help='Max fetch bytes of Kafka consumer'), help='Max fetch bytes of Kafka consumer'),
cfg.IntOpt('kafka_consumer_timeout', default=1.0, cfg.FloatOpt('kafka_consumer_timeout', default=1.0,
help='Default timeout(s) for Kafka consumers'), help='Default timeout(s) for Kafka consumers'),
cfg.IntOpt('pool_size', default=10, cfg.IntOpt('pool_size', default=10,
help='Pool Size for Kafka Consumers'), help='Pool Size for Kafka Consumers'),