Read data from Kafka

Logstash provides an input plugin that reads events from an Apache Kafka topic. 

• Execute the following line to install Kafka:

  bin/logstash-plugin install logstash-input-kafka

• Click here to download a configuration file example.

  input {
          kafka {
                  group_id => "test-kafka"
                  topics => ["testlogtrust"]
                  bootstrap_servers => "localhost:9092"
          }
  }
  output {
          syslog {
                  facility => "local7"
                  severity => "informational"
                  host => "us.elb.relay.logtrust.net"
                  port => "443"
                  appname => "my.app.kafka.topic"         #THIS IS WHERE YOU DEFINE THE TAG
                  protocol => "ssl-tcp"
                  ssl_cert => "/home/logtrust/davidcifl.crt"
                  ssl_key => "/home/logtrust/davidcifl.key"
                  ssl_cacert => "/home/logtrust/chainl.crt"
          }
          stdout{codec => rubydebug }
  }