I'm curious how you got Filebeat to push to Kafka. Did you write a custom modification to Filebeat/libbeat?