I want to build a topology like this, but I don't know the behavior of logstash when elasticsearch dies ( Logstash cannot send the log to Elasticsearch). There are 2 situations that I'm thinking
Logstash will stop getting logs from Kafka.
Logstash keep getting logs from Kafka and save to its queue, if elasticsearch is online, logstash will send logs from the queue to ELS.
LogStash will keep receiving events even if ElasticSearch is unavailable. There are 2 points though:
By default LogStash will keep the events in memory. If LogStash is restarted all pending events are lost. To solve this use a persistent queue
The storage space for pending messages is fixed. If the queue is full no new messages are received. The maximum size can be defined for persistent queues
Apache, Apache Lucene, Apache Hadoop, Hadoop, HDFS and the yellow elephant
logo are trademarks of the
Apache Software Foundation
in the United States and/or other countries.