Использование ELK Stack ver 7.3.2 Linux RedHat 6.9 (Santiago) Kafka Client 2.1
Использование kafka-input-plugin с Logstash.
Kibana запущена и работает.
Эластичный поиск настроен для работы с Kibana.
Kibana работаетна той же виртуальной машине, что и Elastic search.
Hearbeat работает.
Filebeat работает.
Вход Logstash является темой Kafka и настроен для вывода в Elastic.
Я не вижу индекскоторые должны быть сгенерированы Elastic и помещены в Kibana.
Вот простой конфиг для Logstash
input {
kafka {
bootstrap_servers => "nydvalkafvm01.tradeware.com:9092"
topics => ["cat.dev1.service.NJPW7DT004.SM1"]
}
}
output {
elasticsearch {
hosts => ["http://nyuatalcasvm01:9200"]
index => "test_boris"
workers => 1
#user => "elastic"
#password => "changeme"
}
}
Вот вывод консоли
[2019-09-20T22:02:00,444][INFO ][org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] [Consumer clientId=logstash-0, groupId=logstash] Revoking previously assigned partitions []
[2019-09-20T22:02:00,445][INFO ][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] [Consumer clientId=logstash-0, groupId=logstash] (Re-)joining group
[2019-09-20T22:02:00,506][INFO ][logstash.agent ] Successfully started Logstash API endpoint {:port=>9600}
[2019-09-20T22:02:00,521][INFO ][org.apache.kafka.clients.consumer.internals.AbstractCoordinator] [Consumer clientId=logstash-0, groupId=logstash] Successfully joined group with generation 13
[2019-09-20T22:02:00,522][INFO ][org.apache.kafka.clients.consumer.internals.ConsumerCoordinator] [Consumer clientId=logstash-0, groupId=logstash] Setting newly assigned partitions [cat.dev1.service.NJPW7DT004.SM1-0, cat.dev1.service.NJPW7DT004.SM1-1]
Я ожидал увидеть индекс 'test_boris' в Kibana Management. Что-то мне не хватает в конфигурации?