最近两天刚刚由于公司任务刚刚接触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一直报错(看着是用户密码不对)
不知道哪一步有问题。
你的答案