share share share 

Logagent input plugin for Apache Kafka

Input Plugin: Apache Kafka¶

Input plugin for @sematext/logagent. The plugin acts as message consumer for Apache Kafka.

Installation¶

Install @sematext/logagent and logagent-input-kafka npm package:

npm i -g @sematext/logagent 
npm i -g logagent-input-kafka

Configuration¶

# Global options
options:
  includeOriginalLine: false

input:
  kafka: 
    module: logagent-input-kafka
    host: localhost
    port: 9092
    groupId: ExampleTestGroup
    topic: test
    autoCommit: true
    sessionTimeout: 15000
    sslEnable: false
    #For init sslOptions please refer to to https://nodejs.org/api/tls.html
    sslOptions: 
      - rejectUnauthorized: false

output:
  stdout: yaml # use 'pretty' for pretty json and 'ldjson' for line delimited json (default)
  elasticsearch: 
    module: elasticsearch
    url: http://localhost:9200
    index: test

Start logagent¶

logagent --config logagent-kafka-input.yaml