一。先安装jdk
这里我选择的是jdk1.8,其它版本也可以。
配置环境变量这里就不再赘述了
可以参考一下我的这一篇文章：
https://blog.csdn.net/github_39533414/article/details/85218091
https://download.oracle.com/otn-pub/java/jdk/8u201-b09/42970487e3af4f5aa5bca3f542482c60/jdk-8u201-linux-x64.tar.gz
解压jdk.tar ,tar -zxvf xx.tar
配置jdk环境变量
vi /etc/profile ,末尾添加以下
---------------------------------------------
export JAVA_HOME=/joe/jdk1.8
export JRE_HOME=${JAVA_HOME}/jre
export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_PATH}/lib
export PATH=${JAVA_HOME}/bin:$PATH
---------------------------------------------
执行配置文件
source /etc/profile
查看版本 java -version
二 安装Zookeeper
去官网下载压缩包
然后解压
tar -zxvf zookeeper-3.4.14.tar.gz
重命名文件夹
mv zookeeper-3.4.14 zookeeper
进入zookeeper的conf目录，把oo_sample.cfg（样板配置文件）命名为zoo.cfg
cd zookeeper/conf
mv zoo_sample.cfg zoo.cfg 新建data目录
mkdir /home/zixuan/Downlads/zookeeper/data 修改配置文件，修改dataDir的路径，端口根据自己的需要进行修改
vim zoo.cfg 
dataDir的目录改为刚刚建立的data文件夹
进入zookeeper目录启动zookeeper
3.5 启动集群zookeeper服务器（不分先后）
./bin/zkServer.sh start
3.6 查看状态
./bin/zkServer.sh status
这个步骤出现了坑，一直提示 it is probably not running.检查了几遍配置都没问题，最后发现未开通2181 2888 3888端口
10.10.110.xx是该server所在的IP地址.
2888是该server和集群中的leader交换消息所使用的端口.
3888是选举leader时所使用的端口.
firewall-cmd --zone=public --add-port=2181/tcp --permanent
firewall-cmd --reload
-(如果提示firewall没有的话，要安装sudo apt install firewall)
然后开放端口，重启机器
其它操作：
常用操作；
1、Zookeeper服务端启动；
# cd /opt/zookeeper-3.4.10/bin/
#./zkServer.sh start
2、Zookeeper服务端停止；
# cd /opt/zookeeper-3.4.10/bin/
#./zkServer.sh stop
3、Zookeeper服务端重启；
# cd /opt/zookeeper-3.4.10/bin/
#./zkServer.sh restart
4、查看Zookeeper进程；
#ps -ef|grep zookeeper;
5、查看Zookeeper服务端状态；
# cd /opt/zookeeper-3.4.10/bin/
#./zkServer.sh status
6、Zookeeper客户端登陆；
# cd /opt/zookeeper-3.4.10/bin/
#./zkCli.sh -server 127.0.0.1:2181
三 安装Kafka:
下载地址：kafka
解压，修改文件夹名称
创建日志目录
进入config目录，修改server.properties
broker.id=0
port=9092 #端口号
host.name=127.0.0.1 #服务器IP地址，修改为自己的服务器IP
log.dirs=/opt/kafka_2.10-0.10.1.1/logs #日志存放路径，上面创建的目录
zookeeper.connect=localhost:2181 #zookeeper地址和端口，单机配置部署，localhost:2181
修改一下日志目录
先启动zeekeeper,然后启动kafka
./kafka-server-start.sh /home/zixuan/Downloads/kafka/config/server.properties
./bin/kafka-server-start.sh -daemon config/server.properties 后面的是刚刚修改的配置文件的路径
这里报了个错误，kafka-run-class.sh找不到java
这里要重新执行一下
source /etc/profile
然后就行了
创建Topic,打开另一个tab
./kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic test
列出所有Topic
./kafka-topics.sh -list -zookeeper 127.0.0.1:2181
启动生产者Producer并发送消息
./kafka-console-producer.sh --broker-list localhost:9092 --topic test （输入相应的消息，eg:hello kafka;按Ctrl+C结束）
启动消费者Consumer接受消息
./kafka-console-consumer.sh --zookeeper 127.0.0.1:2181 --topic test --from-beginning 这里报了个错误
说是zookeeper不是有效的组织，在网上找了一下发现这是因为kafka在最新版本中已经不使用这个命令了。
参考文章： https://blog.csdn.net/csdn_sunlighting/article/details/81516646
使用下面的命令就可以了。
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
停止kafka
./kafka-server-stop.sh 
kafka一些常用命令
1）、启动kafka命令：
cd /opt/kafka_2.10-0.10.1.1/bin;
./kafka-server-start.sh /opt/kafka_2.10-0.10.1.1/config/server.properties
（2）、停止kafka命令：
./kafka-server-stop.sh
（3）、创建Topic：(创建一个名为test的topic，只有一个副本，一个分区。)
./kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic test
（4）、列出所有Topic：
./kafka-topics.sh -list -zookeeper 127.0.0.1:2181
（5）、启动Producer并发送消息：
./kafka-console-producer.sh --broker-list localhost:9092 --topic test
（输入相应的消息，eg:hello kafka;按Ctrl+C结束）
（6）、启动Consumer并接收消息：
./kafka-console-consumer.sh --zookeeper 127.0.0.1:2181 --topic test --from-beginning
参考文章：
https://blog.csdn.net/bighacker/article/details/86644893
https://blog.csdn.net/bighacker/article/details/86644893
https://blog.csdn.net/xuzhelin/article/details/71514618
https://blog.csdn.net/qq_35188937/article/details/81430267
ubuntu安装kafka
京公网安备 11010502036488号