Logstash: плагин вывода Kafka - проблемы с Bootstrap_Server

Question

Я пытаюсь использовать logstash-output-kafka в logstash:

Файл конфигурации 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 кажется установленным.

Что-то не так с конфигурацией bootstrap_server выходного плагина kafka?я использую logstash v6.4.1, logstash-output-kafka v7.1.3

Answer 1

Я думаю, что в вашей конфигурации есть опечатка.Вместо 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, указывающим на подмножество посредников.