BrokerNotAvailableError: Broker not available

[tronghung-nguyen]

Please help me !
I try connect logagent to kafka apache server
First I install Logagent and the Kafka plugins (assuming nodejs is installed already):
npm i -g '@'sematext/logagent
npm i -g logagent-output-kafka
npm i -g logagent-input-kafka
Then, I created file logagent-kafka-output.yml like you showed:
options:
includeOriginalLine: false
input:
files:
- '/var/log/apache2/access.log'

output:
kafka:
module: logagent-output-kafka
host: localhost
port: 9092
topic: test
requireAcks: 1
sslEnable: false
sslOptions:

[gr0]

Can you provide the Kafka version you are using?

[tronghung-nguyen]

Thank you for your reply ! I am using kafka version kafka_2.13-2.8.0! Thank you very much! Trong Hưng!

…

On Tue, 3 Aug 2021 at 15:19, Rafał Kuć ***@***.***> wrote: Can you provide the Kafka version you are using? — You are receiving this because you authored the thread. Reply to this email directly, view it on GitHub <#281 (comment)>, or unsubscribe <https://github.com/notifications/unsubscribe-auth/AH7MYOTSQPVXLLOWAPJXUP3T26RBBANCNFSM5BJSXUXQ> . Triage notifications on the go with GitHub Mobile for iOS <https://apps.apple.com/app/apple-store/id1477376905?ct=notification-email&mt=8&pt=524675> or Android <https://play.google.com/store/apps/details?id=com.github.android&utm_campaign=notification-email> .

-- Nguyễn Trọng Hưng

[gr0]

@hungnt31 I think I found the reason for the error you are seeing. It was already mentioned in the #119 and the solution was to provide the host and port of the Zookeeper instead of the Kafka broker. In such case the configuration for the output would look as follows:

output:
  kafka:
    module: logagent-output-kafka
    host: localhost
    port: 2181
    topic: test
    requireAcks: 1
    sslEnable: false
    sslOptions:
      - rejectUnauthorized: false

You can try that and see if that works for you.

[tronghung-nguyen]

Thanh rafal ! I will try ! Vào Th 4, 4 thg 8, 2021 lúc 20:40 Rafał Kuć ***@***.***> đã viết:

@hungnt31 <https://github.com/hungnt31> I think I found the reason for the error you are seeing. It was already mentioned in the #119 <#119> and the solution was to provide the host and port of the Zookeeper instead of the Kafka broker. In such case the configuration for the output would look as follows: output: kafka: module: logagent-output-kafka host: localhost port: 2181 topic: test requireAcks: 1 sslEnable: false sslOptions: - rejectUnauthorized: false You can try that and see if that works for you. — You are receiving this because you were mentioned. Reply to this email directly, view it on GitHub <#281 (comment)>, or unsubscribe <https://github.com/notifications/unsubscribe-auth/AH7MYOT7H4COGZRFQUL3HJDT3E7L7ANCNFSM5BJSXUXQ> . Triage notifications on the go with GitHub Mobile for iOS <https://apps.apple.com/app/apple-store/id1477376905?ct=notification-email&mt=8&pt=524675> or Android <https://play.google.com/store/apps/details?id=com.github.android&utm_campaign=notification-email> . --

Nguyễn Trọng Hưng