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 }
    }

Have we answered your question?

If not, please contact our technical support team via email by clicking the button below.

CONTACT US