记一次安装开源kafka

记一次安装开源kafka

因为以前安装过，拷贝包直接复用：

配置好的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配置的信息：

 按照上面这个配置项配置的执行这一句：

请注意的是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相关的命令