参考链接:https://www.jianshu.com/p/d0e630c8f4ae
一、下载 kafka 二进制安装包:
下载地址: http://kafka.apache.org/downloads(注意, Linux 系统下载二进制文件)
二、解压到 /usr/local/services 目录
tar -xzf kafka_2.11-1.1.0.tgz -C /usr/local/services/
三、启动 kafka 服务
kafka需要使用Zookeeper,首先需要启动Zookeeper服务,如果没有的话,可以使用kafka自带的脚本启动一个简单的单一节点Zookeeper实例:
bin/zookeeper-server-start.sh config/zookeeper.properties
如果已经启动了 zookeeper,则直接运行下面的命令:
bin/kafka-server-start.sh config/server.properties
停止 kafka 服务则运行下面命令:
bin/kafka-server-stop.sh config/server.properties
四、kafka 简单使用
4.1、创建一个主题
首先创建一个名为test的topic,只使用单个分区和一个复本
"""
replication-factor :代表副本数
partitions: 代表分区
topic: 后声明你要创建的topic名称
"""
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
4.2、查看主题
现在可以运行list topic命令看到主题:
bin/kafka-topics.sh --list --zookeeper localhost:2181
网友评论