another reason to upgrade to #kafka 2.3.0 or later: https://www.elastic.co/guide/en/logstash/current/plugins-inputs-kafka.html