最近在使用Spring Cloud进行分布式微服务搭建，顺便对集成KafKa的方案做了一些总结，今天详细介绍一下KafKa集群安装过程：
1. 在根目录创建kafka文件夹（service1、service2、service3都创建）
[[email protected] /]# 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
[[email protected] software]# scp -r /software/kafka_2.9.2-0.8.1.1.tgz [email protected]:/software/
[[email protected] software]# scp -r /software/kafka_2.9.2-0.8.1.1.tgz [email protected]:/software/
3.copy /software/kafka_2.9.2-0.8.1.1.tgz到/kafka/目录（service1、service2、service3都执行）
[[email protected] 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都执行）
[[email protected] /]# cd /kafka/
[[email protected] kafka]# tar -zxvf kafka_2.9.2-0.8.1.1.tgz
5.创建kafka消息目录（service1,service2,service3都要创建）
[[email protected] kafka]# mkdir kafkaLogs
6. 修改kafka的配置文件（service1,service2,service3都要配置）
[[email protected] /]# cd /kafka/kafka_2.9.2-0.8.1.1/
[[email protected] kafka_2.9.2-0.8.1.1]# cd config/
[[email protected] config]# ls
consumer.properties log4j.properties producer.properties server.properties test-log4j.properties tools-log4j.properties zookeeper.properties
[[email protected] config]# vi server.properties
7.启动kafka服务
[[email protected] bin]# ./kafka-server-start.sh -daemon ../config/server.properties
[[email protected] bin]# jps
27413 Kafka
27450 Jps
17884 QuorumPeerMain
8.验证kafka集群
[[email protected] 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
[[email protected] 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: See www.slf4j.org/codes.html#… for further details.
10. 在service2上开启consumer程序
[[email protected] 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: See www.slf4j.org/codes.html#… for further details.
11.在producer中发送消息：hello honghu
[[email protected] 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: See www.slf4j.org/codes.html#… for further details.
hello honghu
12. 在consumer中接受到消息
[[email protected] 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: See www.slf4j.org/codes.html#… for further details.
hello honghu
我本人邀约各大BATJ架构大牛共创Java架构师社区群，（群号：673043639）致力于免费提供Java架构行业交流平台，通过这个平台让大家相互学习成长，提高技术，让自己的水平进阶一个档次，成功通往Java架构技术大牛或架构师发展
为什么某些人会一直比你优秀，是因为他本身就很优秀还一直在持续努力变得更优秀，而你是不是还在满足于现状内心在窃喜!
合理利用自己每一分每一秒的时间来学习提升自己，不要再用"没有时间“来掩饰自己思想上的懒惰！趁年轻，使劲拼，给未来的自己一个交代！
希望此文能帮到大家的同时，也听听大家的观点。欢迎留言讨论，加关注，分享你的高见！持续更新！
To-陌霖Java架构
复制代码分享互联网最新文章 关注互联网最新发展