spring boot学习第八篇:kafka
目录
1、安装kafka
1.1确认jdk是否安装Ok
java -version
1.2下载kafka
wget http://archive.apache.org/dist/zookeeper/zookeeper-3.4.14/zookeeper-3.4.14.tar.gz
1.3安装kafka
mkdir zk-3.4.14
tar -xvzf zookeeper-3.4.14.tar.gz -C /home/lighthouse/zk-3.4.14
配置
进入该目录下的conf文件夹中。
zoo_sample.cfg是一个配置文件的样本，需要将这个文件复制并重命名为zoo.cfg:
cp zoo_sample.cfg zoo.cfg
修改配置文件：
vi zoo.cfg
配置环境变量, 使用vim打开etc目录下的profile文件：vim /etc/profile
在末尾配置环境变量，这里需要写入的是：
export ZOOKEEPER_HOME=/home/lighthouse/zk-3.4.14/zookeeper-3.4.14
export PATH=$PATH:$ZOOKEEPER_HOME/bin
写入信息并保存后，需要使配置文件生效，所用的命令为：source /etc/profile
启动zookeeper, 由于配置了环境变量，可以在系统中的任意目录执行启动zookeeper的命令，其执行的实际上是zookeeper的bin文件夹中的zkServer.sh的命令：zkServer.sh start
Zookeeper启动成功：
下载kafka2.2.1：
wget https://archive.apache.org/dist/kafka/2.2.1/kafka_2.12-2.2.1.tgz
解压：
tar -zxvf kafka_2.12-2.2.1.tgz
启动：
nohup bin/kafka-server-start.sh config/server.properties > output.txt &
其中server.properties文件内容如下：
1.4验证kafka
执行命令：bin/kafka-topics.sh –version
看不到版本号
2、连接kafka，并执行命令
2.1创建topic：执行命令：
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
2.2查看topic：执行命令：
bin/kafka-topics.sh --list --zookeeper localhost:2181
2.3使用kafka-console-producer.sh 发送消息：
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
2.4使用kafka-console-consumer.sh消费消息：
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
3、在java中操作kafka
原文地址：https://blog.csdn.net/heming20122012/article/details/135610896
免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！