Logstash：Kafka输出插件-Bootstrap_Server问题

傻瓜

我试图在logstash中使用logstash-output-kafka：

Logstash配置文件

input {
  stdin {}
}

output {
  kafka {
  topic_id => "mytopic"
  bootstrap_server => "[Kafka Hostname]:9092"
  }
}

但是，执行此配置时，出现此错误：

[ERROR][logstash.agent ] Failed to execute action 
{:action=>LogStash::PipelineAction::Create/pipeline_id:main, 
:exception=>"LogStash::ConfigurationError", :message=>"Something is wrong 
with your configuration."

我试图将“ [Kafka主机名]：9092”更改为“ localhost：9092”，但这也无法连接到kafka。只有当我删除bootstrap_server配置（默认为localhost：9092）时，kafka连接才似乎建立。

kafka输出插件的bootstrap_server配置有问题吗？我正在使用logstash v6.4.1，logstash-output-kafka v7.1.3

Giorgos Myrianthous

我认为您的配置中有错字。而不是bootstrap_server您需要定义bootstrap_servers。

input {
  stdin {}
}

output {
  kafka {
  topic_id => "mytopic"
  bootstrap_servers => "your_Kafka_host:9092"
  }
}

根据Logstash文档，

bootstrap_servers
值类型为字符串，
默认值为“ localhost：9092”

，用于引导，生产者仅将其用于获取元数据（主题，分区和副本）。将基于元数据中返回的代理信息来建立用于发送实际数据的套接字连接。格式为host1：port1，host2：port2，该列表可以是代理的子集或指向代理的子集的VIP。

本文收集自互联网，转载请注明来源。

如有侵权，请联系 [email protected] 删除。