Reformatting kafka logs
Change-Id: I853d3db2324c6cf96ccd5c7d08fe295299e38688
diff --git a/common/utils/consulhelpers.py b/common/utils/consulhelpers.py
index 1d2b88f..681aaf4 100644
--- a/common/utils/consulhelpers.py
+++ b/common/utils/consulhelpers.py
@@ -28,8 +28,9 @@
def get_endpoint_from_consul(consul_endpoint, service_name):
"""Look up, from consul, the service name specified by service-name
"""
- log.debug('Retrieving endpoint {} from consul {}'.format(service_name,
- consul_endpoint))
+ log.debug('getting-service-endpoint', consul=consul_endpoint,
+ service=service_name)
+
host = consul_endpoint.split(':')[0].strip()
port = int(consul_endpoint.split(':')[1].strip())