Commit d0941fdf authored by Patrick Godwin's avatar Patrick Godwin
Browse files

kafka.py: fix JSON encoding error (loads -> dumps)

parent 8a877cf2
Pipeline #156500 passed with stages
in 3 minutes and 39 seconds
......@@ -111,7 +111,7 @@ class Client(object):
user-based tags associated with the data
"""
payload = json.loads(data).encode("utf-8")
payload = json.dumps(data).encode("utf-8")
if tags:
if isinstance(tags, list):
tags = '.'.join(tags)
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment