diff options
| author | Eric Brown <browne@vmware.com> | 2016-02-22 22:09:46 -0800 |
|---|---|---|
| committer | Eric Brown <browne@vmware.com> | 2016-02-24 18:37:23 +0000 |
| commit | 1911828638334b4012df07d091ac2ca8a1b19425 (patch) | |
| tree | afd8d074511ffb0a290946cb1f89145cdd58eff5 | |
| parent | 7a537b2c6025449ad94d70440c4707e8ffd80b7c (diff) | |
| download | oslo-messaging-1911828638334b4012df07d091ac2ca8a1b19425.tar.gz | |
Use PortOpt on kafka_default_port
The oslo.config lib includes a PortOpt to simply restrict the
range of integers available for a port type option. This patch
makes use of that.
Change-Id: I8cda92d6c7555b6cb788627d072174ad608fb6de
| -rw-r--r-- | oslo_messaging/_drivers/impl_kafka.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/oslo_messaging/_drivers/impl_kafka.py b/oslo_messaging/_drivers/impl_kafka.py index 11b72bb..0b197fb 100644 --- a/oslo_messaging/_drivers/impl_kafka.py +++ b/oslo_messaging/_drivers/impl_kafka.py @@ -35,8 +35,8 @@ kafka_opts = [ cfg.StrOpt('kafka_default_host', default='localhost', help='Default Kafka broker Host'), - cfg.IntOpt('kafka_default_port', default=9092, - help='Default Kafka broker Port'), + cfg.PortOpt('kafka_default_port', default=9092, + help='Default Kafka broker Port'), cfg.IntOpt('kafka_max_fetch_bytes', default=1024 * 1024, help='Max fetch bytes of Kafka consumer'), |