openstack
/
monasca-log-api
Code Issues Proposed changes

Py3: Fix encoding in _verify_topics method 

Change-Id: I0f75ca4505acfd7840cde7d76174bd8a32354880
This commit is contained in:
Dobroslaw Zybort 2018-09-20 08:33:42 +02:00
parent 572ba3a54f
commit 3ed5838fc1
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
monasca_log_api/healthcheck/kafka_check.py
View File

@ -16,6 +16,7 @@ import collections
from monasca_common.kafka_lib import client
from oslo_log import log
from six import PY3
from monasca_log_api import conf
@ -72,6 +73,9 @@ class KafkaHealthCheck(object):
def _verify_topics(self, kafka_client):
topics = CONF.kafka_healthcheck.kafka_topics
if PY3:
topics = tuple(topic.encode('utf-8') for topic in topics)
for t in topics:
# kafka client loads metadata for topics as fast
# as possible (happens in __init__), therefore this