最近在使用Spring Cloud进行分布式微服务搭建，顺便对集成KafKa的方案做了一些总结，今天详细介绍一下KafKa集群安装过程：
1. 在根目录创建kafka文件夹（service1、service2、service3都创建）
[root@localhost /]# mkdir kafka
2**.通过Xshell上传文件到service1服务器：上传kafka_2.9.2-0.8.1.1.tgz到/software文件夹**
3.远程copy将service1下的/software/kafka_2.9.2-0.8.1.1.tgz到service2、service3
[root@localhost software]# scp -r /software/kafka_2.9.2-0.8.1.1.tgzroot@192.168.2.212:/software/
[root@localhost software]# scp -r /software/kafka_2.9.2-0.8.1.1.tgzroot@192.168.2.213:/software/
3.copy /software/kafka_2.9.2-0.8.1.1.tgz到/kafka/目录（service1、service2、service3都执行）
[root@localhost software]# cp /software/kafka_2.9.2-0.8.1.1.tgz /kafka/
4.安装解压kafka_2.9.2-0.8.1.1.tgz（service1、service2、service3都执行）
[root@localhost /]# cd /kafka/
[root@localhost kafka]# tar -zxvf kafka_2.9.2-0.8.1.1.tgz
5.创建kafka消息目录（service1,service2,service3都要创建）
[root@localhost kafka]# mkdir kafkaLogs
6. 修改kafka的配置文件（service1,service2,service3都要配置）
[root@localhost /]# cd /kafka/kafka_2.9.2-0.8.1.1/
[root@localhost kafka_2.9.2-0.8.1.1]# cd config/
[root@localhost config]# ls
consumer.properties log4j.properties producer.properties server.properties test-log4j.properties tools-log4j.properties zookeeper.properties
[root@localhost config]# vi server.properties
7.启动kafka服务
[root@localhost bin]# ./kafka-server-start.sh -daemon ../config/server.properties
[root@localhost bin]# jps
27413 Kafka
27450 Jps
17884 QuorumPeerMain
8.验证kafka集群
[root@localhost bin]# ./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 1 --topic test
Created topic "test".
9.在service1上开启producer程序
./kafka-console-producer.sh --broker-list 192.168.2.211:9092 --topic test
[root@localhost bin]# ./kafka-console-producer.sh --broker-list 192.168.2.211:9092 --topic test
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: Seewww.slf4j.org/codes.html#…for further details.
10. 在service2上开启consumer程序
[root@localhost bin]# ./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: Seewww.slf4j.org/codes.html#…for further details.
11.在producer中发送消息：hello honghu
[root@localhost bin]# ./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: Seewww.slf4j.org/codes.html#…for further details.
hello honghu
12. 在consumer中接受到消息
[root@localhost bin]# ./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: Seewww.slf4j.org/codes.html#…for further details.
hello honghu
我本人邀约各大BATJ架构大牛共创Java架构师社区群，（群号：673043639）致力于免费提供Java架构行业交流平台，通过这个平台让大家相互学习成长，提高技术，让自己的水平进阶一个档次，成功通往Java架构技术大牛或架构师发展
为什么某些人会一直比你优秀，是因为他本身就很优秀还一直在持续努力变得更优秀，而你是不是还在满足于现状内心在窃喜!
合理利用自己每一分每一秒的时间来学习提升自己，不要再用"没有时间“来掩饰自己思想上的懒惰！趁年轻，使劲拼，给未来的自己一个交代！
网友评论