Logback Elasticsearch Appender

Send log events directly from Logback to Elasticsearch

License

License

Categories

Categories

Logback Application Layer Libs Logging Search Business Logic Libraries Elasticsearch
GroupId

GroupId

com.linagora
ArtifactId

ArtifactId

logback-elasticsearch-appender
Last Version

Last Version

1.8.0
Release Date

Release Date

Type

Type

jar
Description

Description

Logback Elasticsearch Appender
Send log events directly from Logback to Elasticsearch
Project URL

Project URL

https://github.com/internetitem/logback-elasticsearch-appender
Project Organization

Project Organization

Internet Item
Source Code Management

Source Code Management

https://github.com/linagora/logback-elasticsearch-appender

Download logback-elasticsearch-appender

How to add to project

<!-- https://jarcasting.com/artifacts/com.linagora/logback-elasticsearch-appender/ -->
<dependency>
    <groupId>com.linagora</groupId>
    <artifactId>logback-elasticsearch-appender</artifactId>
    <version>1.8.0</version>
</dependency>
// https://jarcasting.com/artifacts/com.linagora/logback-elasticsearch-appender/
implementation 'com.linagora:logback-elasticsearch-appender:1.8.0'
// https://jarcasting.com/artifacts/com.linagora/logback-elasticsearch-appender/
implementation ("com.linagora:logback-elasticsearch-appender:1.8.0")
'com.linagora:logback-elasticsearch-appender:jar:1.8.0'
<dependency org="com.linagora" name="logback-elasticsearch-appender" rev="1.8.0">
  <artifact name="logback-elasticsearch-appender" type="jar" />
</dependency>
@Grapes(
@Grab(group='com.linagora', module='logback-elasticsearch-appender', version='1.8.0')
)
libraryDependencies += "com.linagora" % "logback-elasticsearch-appender" % "1.8.0"
[com.linagora/logback-elasticsearch-appender "1.8.0"]

Dependencies

compile (1)

Group / Artifact Type Version
com.fasterxml.jackson.core : jackson-core jar 2.8.0

provided (4)

Group / Artifact Type Version
ch.qos.logback : logback-classic jar 1.1.7
ch.qos.logback : logback-access jar 1.1.7
org.slf4j : slf4j-api jar 1.7.21
com.amazonaws : aws-java-sdk-core jar 1.11.31

test (2)

Group / Artifact Type Version
junit : junit jar 4.12
org.mockito : mockito-all jar 1.10.19

Project Modules

There are no modules declared in this project.

Logback Elasticsearch Appender

Build status

This project is a fork of https://github.com/internetitem/logback-elasticsearch-appender with several commits taken from https://github.com/PeterFokkinga/logback-elasticsearch-appender

Send log events directly from Logback to Elasticsearch. Logs are delivered asynchronously (i.e. not on the main thread) so will not block execution of the program. Note that the queue backlog can be bounded and messages can be lost if Elasticsearch is down and either the backlog queue is full or the producer program is trying to exit (it will retry up to a configured number of attempts, but will not block shutdown of the program beyond that). For long-lived programs, this should not be a problem, as messages should be delivered eventually.

This software is dual-licensed under the EPL 1.0 and LGPL 2.1, which is identical to the Logback License itself.

Usage

Include slf4j and logback as usual (depending on this library will not automatically pull them in).

In your pom.xml (or equivalent), add:

 <dependency>
    <groupId>com.internetitem</groupId>
    <artifactId>logback-elasticsearch-appender</artifactId>
    <version>1.6</version>
 </dependency>

In your logback.xml:

    <appender name="ELASTIC" class="com.internetitem.logback.elasticsearch.ElasticsearchAppender">
        <url>http://yourserver/_bulk</url>
        <index>logs-%date{yyyy-MM-dd}</index>
        <type>tester</type>
        <loggerName>es-logger</loggerName> <!-- optional -->
        <errorLoggerName>es-error-logger</errorLoggerName> <!-- optional -->
        <connectTimeout>30000</connectTimeout> <!-- optional (in ms, default 30000) -->
        <errorsToStderr>false</errorsToStderr> <!-- optional (default false) -->
        <includeCallerData>false</includeCallerData> <!-- optional (default false) -->
        <logsToStderr>false</logsToStderr> <!-- optional (default false) -->
        <maxQueueSize>104857600</maxQueueSize> <!-- optional (default 104857600) -->
        <maxRetries>3</maxRetries> <!-- optional (default 3) -->
        <readTimeout>30000</readTimeout> <!-- optional (in ms, default 30000) -->
        <sleepTime>250</sleepTime> <!-- optional (in ms, default 250) -->
        <rawJsonMessage>false</rawJsonMessage> <!-- optional (default false) -->
        <includeMdc>false</includeMdc> <!-- optional (default false) -->
        <excludedMdcKeys>stacktrace</excludedMdcKeys> <!-- optional (default empty) -->
        <maxMessageSize>100</maxMessageSize> <!-- optional (default -1 -->
        <authentication class="com.internetitem.logback.elasticsearch.config.BasicAuthentication" /> <!-- optional -->
        <properties>
            <property>
                <name>host</name>
                <value>${HOSTNAME}</value>
                <allowEmpty>false</allowEmpty>
            </property>
            <property>
                <name>severity</name>
                <value>%level</value>
            </property>
            <property>
                <name>thread</name>
                <value>%thread</value>
            </property>
            <property>
                <name>stacktrace</name>
                <value>%ex</value>
            </property>
            <property>
                <name>logger</name>
                <value>%logger</value>
            </property>
        </properties>
        <headers>
            <header>
                <name>Content-Type</name>
                <value>application/json</value>
            </header>
        </headers>
    </appender>

    <root level="info">
        <appender-ref ref="FILELOGGER" />
        <appender-ref ref="ELASTIC" />
    </root>

    <logger name="es-error-logger" level="INFO" additivity="false">
        <appender-ref ref="FILELOGGER" />
    </logger>

    <logger name="es-logger" level="INFO" additivity="false">
        <appender name="ES_FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
            <!-- ... -->
            <encoder>
                <pattern>%msg</pattern> <!-- This pattern is important, otherwise it won't be the raw Elasticsearch format anymore -->
            </encoder>
        </appender>
    </logger>

Configuration Reference

  • url (required): The URL to your Elasticsearch bulk API endpoint
  • index (required): Name if the index to publish to (populated using PatternLayout just like individual properties - see below)
  • type (optional): Elasticsearch _type field for records. Although this library does not require type to be populated, Elasticsearch may, unless the configured URL includes the type (i.e. {index}/{type}/_bulk as opposed to /_bulk and /{index}/_bulk). See the Elasticsearch Bulk API documentation for more information
  • sleepTime (optional, default 250): Time (in ms) to sleep between attempts at delivering a message
  • maxRetries (optional, default 3): Number of times to attempt retrying a message on failure. Note that subsequent log messages reset the retry count to 0. This value is important if your program is about to exit (i.e. it is not producing any more log lines) but is unable to deliver some messages to ES
  • connectTimeout (optional, default 30000): Elasticsearch connect timeout (in ms)
  • readTimeout (optional, default 30000): Elasticsearch read timeout (in ms)
  • includeCallerData (optional, default false): If set to true, save the caller data (identical to the AsyncAppender's includeCallerData)
  • errorsToStderr (optional, default false): If set to true, any errors in communicating with Elasticsearch will also be dumped to stderr (normally they are only reported to the internal Logback Status system, in order to prevent a feedback loop)
  • logsToStderr (optional, default false): If set to true, dump the raw Elasticsearch messages to stderr
  • maxQueueSize (optional, default 104,857,600 = 200MB): Maximum size (in characters) of the send buffer. After this point, logs will be dropped. This should only happen if Elasticsearch is down, but this is a self-protection mechanism to ensure that the logging system doesn't cause the main process to run out of memory. Note that this maximum is approximate; once the maximum is hit, no new logs will be accepted until it shrinks, but any logs already accepted to be processed will still be added to the buffer
  • loggerName (optional): If set, raw ES-formatted log data will be sent to this logger
  • errorLoggerName (optional): If set, any internal errors or problems will be logged to this logger
  • rawJsonMessage (optional, default false): If set to true, the log message is interpreted as pre-formatted raw JSON message.
  • includeMdc (optional, default false): If set to true, then all MDC values will be mapped to properties on the JSON payload.
  • excludedMdcKeys (optional, default empty): comma separated (extra whitespace is fine) list of case sensitive MDC keys that should not be mapped automatically to properties; only useful when includeMdc is set to true
  • maxMessageSize (optional, default -1): If set to a number greater than 0, truncate messages larger than this length, then append ".." to denote that the message was truncated
  • authentication (optional): Add the ability to send authentication headers (see below)

The fields @timestamp and message are always sent and can not currently be configured. Additional fields can be sent by adding <property> elements to the <properties> set.

  • name (required): Key to be used in the log event
  • value (required): Text string to be sent. Internally, the value is populated using a Logback PatternLayout, so all Conversion Words can be used (in addition to the standard static variable interpolations like ${HOSTNAME}).
  • allowEmpty (optional, default false): Normally, if the value results in a null or empty string, the field will not be sent. If allowEmpty is set to true then the field will be sent regardless
  • type (optional, default String): type of the field on the resulting JSON message. Possible values are: String, int, float, boolean and object. Use object if the value is the string representation of a JSON object or array ie. {"k" : true}or [1,2,3,].

Groovy Configuration

If you configure logback using logback.groovy, this can be configured as follows:

  import com.internetitem.logback.elasticsearch.ElasticsearchAppender

  appender("ELASTIC", ElasticsearchAppender){
  	url = 'http://yourserver/_bulk'
  	index = 'logs-%date{yyyy-MM-dd}'
  	type = 'log'
  	rawJsonMessage = true
  	errorsToStderr = true
  	authentication = new BasicAuthentication()
  	def configHeaders = new HttpRequestHeaders()
  	configHeaders.addHeader(new HttpRequestHeader(name: 'Content-Type', value: 'text/plain'))
  	headers = configHeaders
  }

  root(INFO, ["ELASTIC"])

Authentication

Authentication is a pluggable mechanism. You must specify the authentication class on the XML element itself. The currently supported classes are:

  • com.internetitem.logback.elasticsearch.config.BasicAuthentication - Username and password are taken from the URL (i.e. http://username:password@yourserver/_bulk)
  • com.internetitem.logback.elasticsearch.config.AWSAuthentication - Authenticate using the AWS SDK, for use with the Amazon Elasticsearch Service (note that you will also need to include com.amazonaws:aws-java-sdk-core as a dependency)

Logback Access

Included is also an Elasticsearch appender for Logback Access. The configuration is almost identical, with the following two differences:

  • The Appender class name is com.internetitem.logback.elasticsearch.ElasticsearchAccessAppender
  • The value for each property uses the Logback Access conversion words.
com.linagora

LINAGORA

Versions

Version
1.8.0