for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
class Encoder(object):
@staticmethod
def encode(msg):
"""
Don't change the message at all
:param msg:
return msg
mre /
kafka-influxdb
