Logstash upgrade 2.x -> 5.x and kafka input

Looks like there is a pull request about this but was not committed. Unless somebody knows a workaround I guess I'll use the different topics.