I have an app written using the Twisted framework, that communicates various data (mostly – log entries in JSON format) to a variety of logging servers using output plug-ins. I would like to make it able to send the data to a Kafka server, too – but I am hitting some kind of problem that I don’t know how to solve.