Add a write_kafka output with similar properties to the amqp one.