logstash能同时接受kafka和rest(http)吗

sqyvllje  于 2021-06-05  发布在  Kafka
关注(0)|答案(1)|浏览(255)

我在找这样的东西

input{
     tcp{
          port=>9600
          type=>sylog
        }
     kafka{
     bootstrap_servers=>"localhost"9092"
     topics=>["my_log"]
           }
46scxncf

46scxncf1#

是的,会有用的,只要修好你的 bootstrap_servers 行至:

bootstrap_servers=>"localhost:9092"

这取决于您的业务逻辑,但通常我建议您将输入分为两个不同的文件 /etc/logstash/conf.d .
输入\u tcp.conf

input {
  tcp {
    port=>9600
    type=>sylog
  }
}

输入\u kafka.conf

input {
  kafka { 
    bootstrap_servers=>"localhost:9092"
    topics=>["my_log"]
  }
}

相关问题