Сбой вывода Fluentd Kafka через SASL_SSL с ошибкой - PullRequest
Новая
       30

Сбой вывода Fluentd Kafka через SASL_SSL с ошибкой

0 голосов
/ 13 марта 2019

Я пытаюсь отправить журналы приложений с помощью агента fluentd брокерам Kafka, которые имеют механизм аутентификации SASL_SSL. Ниже приведен файл конфигурации fluentd 

<source>
  @type tail
  path /root/test/gta.log
  pos_file /tmp/gta.pos
  tag gtalogs
  read_from_head true
  <parse>
    @type none
  </parse>
</source>

<match **>
    @type kafka
    brokers "localhost:9093"
    ssl_ca_cert "/root/test/kafka.crt"
    username "temp"
    password "temp123"
    output_data_type json
    max_send_retries 5
    sasl_over_ssl true
    default_topic gtatopic
    flush_interval 5s
    get_kafka_client_log true
</match>

Ниже представлены версии с самоцветами и кафками:

  • Кафка сервер 2.1.0
  • fluent-plugin-kafka 0.9.0
  • fluentd-1.1.1
  • рубинового Кафка-0.7.5
  • версия клиента kafka: kafka-clients-2.1.0

При запуске агента fluentd выдает следующую ошибку:

2019-03-13 10:18:02 +0400 [warn]: # 0 Возникла исключительная ситуация отправки: не удалось подключиться ни к одному из посредников семян: - kafka: // localhost: 9093: ошибка соединения Errno :: ECONNRESET: сброс соединения по пиру - SSL_connect

2019-03-13 10:18:02 +0400 [info]: инициализированный # 0 kafka производитель: kafka

2019-03-13 10:18:02 +0400 [warn]: # 0 ошибка транзакции emit: error_class = Kafka :: ConnectionError error = "Не удалось подключиться ни к одному из семенных брокеров: \ n-kafka: / / localhost: 9093: ошибка соединения Errno :: ECONNRESET: сброс соединения по пиру - SSL_connect "location =" / test / fluentd / lib / ruby ​​/ gems / 2.4.0 / gems / ruby-kafka-0.7.5 / lib / kafka /cluster.rb:396:in `fetch_cluster_info '" tag = "gtalogs"

2019-03-13 10:18:02 +0400 [ошибка]: # 0 не удалось создать журнал событий fluentd tag = "fluent.info" event = {"worker" => 0, "message" => " fluentd worker теперь останавливает работника = 0 "} error_class = OpenSSL :: SSL :: SSLError error =" SSL_connect SYSCALL вернул = 5 errno = 0 состояние = SSLv2 / v3 сервер чтения привет A "

...