Конфигурация выходного плагина Fluentd Kafka - PullRequest
Новая
       31

Конфигурация выходного плагина Fluentd Kafka

0 голосов
/ 21 февраля 2019

Я пытаюсь использовать плагин Kafka Producer во Fluentd (версия 0.7.9), прежде всего я хотел бы знать, хорошо ли выглядит следующий конфиг: 

<match log>

 @type kafka_buffered

 brokers mykafka:9093

 topic_key  my_queue

 #how to configure the SASL PLAIN authentication?

 ssl_ca_cert /opt/td-agent/embedded/ssl/cert.pem
 username myuser_here
 password mypass_here

</match>

Проблема в том, что яполучить эти сообщения, не получая ничего в теме: 

 2019-02-21 10:28:10 +0100 [warn]: #0 Send exception occurred: Connection reset by peer
 2019-02-21 10:28:10 +0100 [warn]: #0 Exception Backtrace : /opt/td-agent/embedded/lib/ruby/2.4.0/openssl/buffering.rb:181:in `sysread_nonblock'

 2019-02-21 10:28:10 +0100 [info]: #0 initialized kafka producer: kafka
 2019-02-21 10:28:10 +0100 [warn]: #0 failed to flush the buffer. retry_time=0 next_retry_seconds=2019-02-21 10:28:11 +0100 chunk="58264142c3dc4a2c86869aae9a9a033d" error_class=Errno::ECONNRESET error="Connection reset by peer"

Большое спасибо

...