是否可以使用logback appender将日志发送到Kafka/rabbit-MQ，然后发送到Logstash（弹性堆栈）？

Question

null

    <appender name="STASH"
              class="net.logstash.logback.appender.LogstashTcpSocketAppender">
        <destination>localhost:5000</destination>

        <encoder
                class="net.logstash.logback.encoder.LoggingEventCompositeJsonEncoder">
            <providers>
                <mdc/>
                <context/>
                <logLevel/>
                <loggerName/>

                <pattern>
                    <pattern>
                        {
                        "serviceName": "clients-component",
                        "type": "business-capability"
                        }
                    </pattern>
                </pattern>

                <threadName/>
                <message/>
                <logstashMarkers/>
                <stackTrace/>
            </providers>
        </encoder>
    </appender>

input { tcp { port => 5000 codec => "json" } } 

output { elasticsearch { hosts => ["localhost:9200"]} }

Answer 1

您可以毫无问题地将Logstash配置为从消息队列消费。

目前，Logstash有一些消息队列的输入，如Kafka、RabbitMQ和Redis。

由于使用的是AWS，logstash也有用于AWS SQS的输入。