At present, the security-protocols of kafka mainly include the following
PLAINTEXT, SSL, SASL_PLAINTEXT, SASL_SSL. But I checked the kafka-output documentation: Configure the Kafka output | Filebeat Reference [8.8] | Elastic, and found that there is no option for PLAINTEXT. How can I use PLAINTEXT to connect to my kafka brokers?
The error I have received so far is:
kafka: couldn't fetch broker metadata (check that your client and broker are using the same encryption and authentication settings)
What does your filebeat configuration looks like?
PLAINTEXT is the default if you do not configure any security layer on Kafka.
Thanks, it seems that there are other problems. My configuration is posted below. I can produce and consume messages with this kafka broker address and topic in python.
max_message_bytes: 1000000 # 1M
I solved it finnaly. We should give a correct
version field. In this case, when I use
0.8.2.0, it worked well, while other versions will fail.
In fact, My kafka version is
2.2.1 if I run
kafka-broker-api-versions.sh to see the kafka broker version.
This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.