Logagent Plugin: ZeroMQ

Input plugin for @sematext/logagent. The plugin acts as message consumer using ZeroMQ.

Input plugins support three types of messaging patterns

• Publish-subscripe
• Request-response
• fire-and-forget some times called pipeline

At the moment plugin is not able to configure socket parameter, by default fire-and-forget patter has configured by default linger to 500 and connect_timeout to 2500 ms

Installation

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

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

Configuration

# Global options
options:
  includeOriginalLine: false

input:
  zeromq: 
    module: logagent-input-zeromq
    host: 127.0.0.1
    port_zmq: 3000
    # for Fire-and-forget = 0  Request-response = 1  Publish-subscribe= 2
    pattern: 1
    topic: topic-example

output:
  stdout: ldjson # use 'pretty' for pretty json or 'yaml' 
  # elasticsearch: 
  #   module: elasticsearch
  #  url: http://localhost:9200
  #  index: test

Start logagent

logagent --config logagent-zeromq-input.yml