最近两天刚刚由于公司任务刚刚接触kafka,目前在本地上测试了一下,跑通了给出的Demo程序,但看到是用了SASL_PLAINTEXT想在本地试一试加上协议(ps:后续kafka要在服务器上部署)。
在网上搜了很多,发现大致要配的东西如下:
1、新建kafka_server_jaas.conf和kafka_zk_jaas.conf

2、配置server.properties和zookeeper.properties


3、为kafka和zookeeper启动项配置conf文件
4、运行zookeeper后运行kafka一直报错(看着是用户密码不对)

不知道哪一步有问题。