Для мониторинга процессов микросервисов моя команда настроила стек ELK с выходом, направленным непосредственно в Elastic Search, а не в Logstash.Мы используем ELK версии 7.3.2 с базовой лицензией и работаем под Linux RedHat.
Я смог установить Logstash с вводом и выводом Kafka в Elastic Search, и я также создал свою собственную тему для тестирования.
Я настроил Logstash для просмотра своей темы и смог успешно отправить сообщение через консольную команду Kafka, создать индекс и показать его в Kibana, а также имя моей темы в MetricBeat.
Как мне либо создать скрипт bash / shell / config, чтобы отправить сообщение о проверке состояния в Kafka, либо использовать другой способ, чтобы отправить сообщение о проверке состояния через Kafka и получить ответ о проверке состояния и использовать его?для мониторинга процесса.