Kafka 在CentOS下安装

下载Kafka

注意：下载并使用Kafka前，必须安装Zookeeper！zookeeper安装文档：https://blog.csdn.net/u014641168/article/details/123901786

kafka官网下载地址：https://kafka.apache.org/downloads

linux中使用wget命令，远程下载kafka

wget https://archive.apache.org/dist/kafka/2.8.1/kafka_2.12-2.8.1.tgz  --no-check-certificate

版本的话当然越新越好，对SpringBoot本版暂无要求，如果你有想说的，欢迎在评论区讨论。

安装

1、解压压缩包到

/usr/local/

目录

tar -zxvf ./kafka_2.12-2.8.1.tgz -C /usr/local/

2、进入

/usr/local/

目录

cd /usr/local/

3、修改原始名称

mv./kafka_2.12-2.8.1/ kafka2.12

4、进入Kafka并修改配置文件

cd kafka2.12
vim config/server.properties

修改其中的：

broker.id=0
log.dir=/usr/local/kafka/kafka-logs

#配置zookeeper管理kafka的路径
zookeeper.connect=localhost:2181

#配置kafka的监听端口
listeners=PLAINTEXT://:9092

#把kafka的地址端口注册给zookeeper，如果是远程访问要改成外网IP
advertised.listeners=PLAINTEXT://外网IP:外网端口

启动

必须先启动zookeeper！！！

kafka启动命令：

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

kafka停止命令：

bin/kafka-server-stop.sh

创建Topic

1、进入到Kafka目录下，创建一个名为

testTopic

的Topic。

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

2、查看创建的Topic列表。

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

测试通信

1、连接生产者，命令后面需要对应 Topic 名称。

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic testTopic

2、连接消费者，需要连接消费者的Topic

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic testTopic --from-beginning

通过以上步骤，就成功安装kafka了，这个时候就可以通过java开发工具连接进行开发了。

详细介绍：https://www.cnblogs.com/yclh/p/14894712.html

其他

自己做的小商城，开发技术 SpringCloud + Nacos + 支付宝支付 + Vue

感兴趣的可以相互讨论技术！

传送门：https://store.ityao.cn/

顺便说一下，国内又一款开源软件Wall，搭建特别简单，可以搭建个人照片墙和视频墙，有兴趣可以看下教程：https://blog.csdn.net/u014641168/article/details/129396364