Logsta sh создание трубопроводов из Кафки не работает

Question

Я пытаюсь получить данные из Kafka topi c для запуска в ELK-стек с Logsta sh, но не могу получить данные для перемещения.

Я отредактировал logsta sh .conf к следующему:

input {
        tcp {
            port => 5000
        }
        kafka {
            bootstrap_servers => "broker:29092"
            topics => ["PLACES_ROWKEY"]
        }
}

## Add your filters / logstash plugins configuration here

output {
        elasticsearch {
                hosts => ["elasticsearch:9200"]
                user => "elastic"
                password => "changeme"
                index => "from_logstash"
        }
}

Я запускаю эту настройку в Docker, если это имеет значение (брокер - это имя хоста для контейнера брокера Kafka). Я перезапускаю Logsta sh, но не вижу никаких новых индексов вasticsearch