因为以前安装过,拷贝包直接复用:

配置好的kafka_2.12-2.8.0+ SCRAM-SHA-256-kafka文档类资源-CSDN下载配置好的kafka_2.12-2.8.0+ SCRAM-SHA-256,打开修改少量配置即可用更多下载资源、学习资料请访问CSDN下载频道.https://download.csdn.net/download/qq_30168227/54200012

下载下来之后解压放到服务器上,请注意的是服务器要已经安装好了jdk。

1.接下来修改部分配置

2.修改现在压缩包中的IP为自己服务器的IP

现在压缩包中的IP都是29.23.91.106,可以grep然后都替换了。

3.修改/etc/hosts文件

修改服务器的hosts文件,将第一步中提到的本机IP与localhost对应起来,例如增加

29.23.91.106        localhost

4.将认证用户增加到zk中

下图是压缩包中的kafka_server_jaas.conf配置的信息:

 按照上面这个配置项配置的执行这一句(朋友提醒:要先启动zk,即进行了第五步的“启动zk步骤”):

请注意的是password与name要与文件中的保持一致。

如果这一步没执行,会报错:

Authentication failed during authentication due to invalid credentials with SASL mechanism SCRAM-SHA-256...

5.启动kafka(默认zk监听2181,kafka监听9092)

启动zk:

sh kafka/bin/zookeeper-server-start.sh -daemon kafka/config/zookeeper.properties

启动kafka :

sh kafka/bin/kafka-server-start.sh -daemon kafka/config/server.properties

增加topic:

sh kafka/bin/kafka-topics.sh --create --topic test_topic --replication-factor 1 --partitions 1 --zookeeper 29.23.91.106:2181

查看topic列表:

sh kafka/bin/kafka-topics.sh --list --zookeeper 29.23.91.106:2181

6.其他控制此kafka相关的命令

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐