赞
踩
因为以前安装过,拷贝包直接复用:
下载下来之后解压放到服务器上,请注意的是服务器要已经安装好了jdk。
现在压缩包中的IP都是29.23.91.106,可以grep然后都替换了。
修改服务器的hosts文件,将第一步中提到的本机IP与localhost对应起来,例如增加
29.23.91.106 localhost
下图是压缩包中的kafka_server_jaas.conf配置的信息:
按照上面这个配置项配置的执行这一句(朋友提醒:需要先启动zk,即进行了第五步的“启动zk步骤”):
请注意的是password与name要与文件中的保持一致。
如果这一步没执行,会报错:
Authentication failed during authentication due to invalid credentials with SASL mechanism SCRAM-SHA-256...
sh kafka/bin/zookeeper-server-start.sh -daemon kafka/config/zookeeper.properties
sh kafka/bin/kafka-server-start.sh -daemon kafka/config/server.properties
sh kafka/bin/kafka-topics.sh --create --topic test_topic --replication-factor 1 --partitions 1 --zookeeper 29.23.91.106:2181
sh kafka/bin/kafka-topics.sh --list --zookeeper 29.23.91.106:2181
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。