Not able to consume input from a kafka-topic

That appears correct according to example 2 here: Working with plugins | Logstash Reference [8.11] | Elastic