logstash使用http收集日志送Kafka

安装Logstash

tar xf logstash-7.7.0.tar.gz
# 检查JAVA_HOME
echo $JAVA_HOME
${JAVA_HOME}/bin/java -version

新增配置文件

cd logstash-7.7.0/config
vim kong_log.conf

input {
  http {
    id => "kong_log_http_1"
    port => 7000,
    codec => json
  }
}
output {
  kafka {
    topic_id => "konglogs"
    bootstrap_servers => "192.168.2.130:9093",
    codec => json
  }
}

启动logstash

cd logstash-7.7.0
./bin/logstash -f ./config/kong_log.conf
# 启动到后台
nohup ./bin/logstash -f ./config/kong_log.conf &> /dev/null &

logstash使用http收集日志送Kafka

原文：https://www.cnblogs.com/Peter2014/p/13214860.html