kafka单节点部署
书接上回：zookeeper单节点部署，手把手从零到一
建议配套观看
2、kafka的单节点部署
2.1、下载
这里如果和zookeeper相似的就不再赘述，直接上命令
wget https://archive.apache.org/dist/kafka/2.8.2/kafka_2.12-2.8.2.tgz
2.2、解压缩
tar -zxvf kafka_2.12-2.8.2.tgz -C /opt/service/
2.3、目录分析
一般情况下，我们需要关注的文件有三个
bin：里面会涉及一些可执行的sh文件
config：服务的相关配置
logs：一般是启动服务之后才会出现的文件夹，记录了服务的日志信息
2.4、启动
1、在kafka文件夹中创建logs文件夹，进入kafka文件，运行命令：
mkdir logs
2、用vim编辑器打开config文件下的server.properties文件，运行命令：
vim config/server.properties
要修改的配置如下：
1、确认zookeeper.connect这个参数值中的ip和端口号，默认为本机的2181端口，如果上文中zookeeper端口有修改的，这个地方要同步修改
2、修改log.dirs的参数值为/opt/service/kafka_2.12-2.8.2/logs（对应你们自己的logs）
3、后台启动kafka，进入bin目录下，运行命令：
./kafka-server-start.sh -daemon ../config/server.properties
4、打开一个新窗口，且称其名字为win1，进入kafka的bin目录下，测试服务是否正常
# 创建一个topic ：test
./kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic test
./kafka-topics.sh --list --zookeeper 127.0.0.1:2181
5、消息测试
启动生产者Producer发送消息，运行命令：
./kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test
这时另外再开一个窗口，且称其为win2，进入kafka的bin路径下，运行命令：
./kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --from-beginning --topic test
然后就可以从win1发送消息，查看win2是否接收到
win1窗口截图：
win2窗口截图：
6、删除测试的topic
#删除测试的topic
./kafka-topics.sh --delete --zookeeper 127.0.0.1:2181 --topic test
#验证topic是否还存在
./kafka-topics.sh --list --zookeeper 127.0.0.1:2181
可以发现test已经消失了
结束！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/147336.html
