报错信息:
Bootstrap broker localhost:9092 disconnected
解决方案
1.如果开启了Kerberos
需要加上安全协议:SASL_PLAINTEXT
2.如果没有开启Kerberos,但是有SASL 、 PLAINTEXT +、ACL权限控制
需要在jaas.conf文件中加上用户信息,并且将jaas.conf作为参数传入producer/consumer命令中
报错信息
WARN Error while fetching metadata with correlation id 1
解决方案
出现这个报错说明通过了认证,但是没有通过授权,需要使用kafka-acls.sh命令给用户赋相应的读写权限
网友评论