一、Mac环境
1、下载Kafka:Apache Kafka
2、这里我选择的版本是kafka_2.12-3.7.0,下载最新版的Kafka二进制文件,解压到你喜欢的目录(建议目录不要带中文)。
3、启动ZooKeeper服务,Kafka需要使用ZooKeeper,所以首先需要启动ZooKeeper服务,注意了Kafka是自带了Zookeeper的
4、进入到bin目录下执行下面命令
./zookeeper-server-start.sh ../config/zookeeper.properties
#或者
sh zookeeper-server-start.sh ../config/zookeeper.properties
1、如果启动报错:INFO ZooKeeper audit is disabled.
2、修改config目录下的zookeeper.properties,添加audit.enable=true
3、关闭窗口重新执行上面的启动Zookeeper命令,看到截图中的result=success即表示Zookeeper启动成功
5、启动Kafka服务器:
./kafka-server-start.sh ../config/server.properties
#或者
sh kafka-server-start.sh ../config/server.properties
看到截图这个就表示Kafka启动成功了
6、创建一个测试主题(可选):
参数说明:
- --create:表示创建操作
- --bootstrap-server localhost:2181:指定zookeeper的地址和端口
- --topic:指定topic的名称
- --partitions:指定分片数
- --replication-factor:指定每个分片的副本数量
./kafka-topics.sh --create --bootstrap-server localhost:2181 --replication-factor 1 --partitions 1 --topic test1
#或者
sh kafka-topics.sh --create --bootstrap-server localhost:2181 --replication-factor 1 --partitions 1 --topic test1
#输出:Created topic "test1".
6.1、#如果你创建Topic失败,如下截图:原因就是连接服务超时,导致创建Topic失败
6.2、你需要进入到kafka_2.12-3.7.0下的conf目录下,找到server.perperties配置文件
6.3、用编辑器打开,这里我用的是VSCode,找到#listeners=PLAINTEXT://:9092这行修改成如下:
6.4、在bin目录下执行下面命令关闭kafka然后执行上面启动Kafka启动命令重启kafka
./kafka-server-stop.sh
#或者
sh kafka-server-stop.sh
7、查看topic列表(可选)
./kafka-topics.sh --list --bootstrap-server localhost:2181
#或者
sh kafka-topics.sh --list --bootstrap-server localhost:2181
# 输出:test1
8、查看某一个Topic的详细信息
./kafka-topics.sh --describe -bootstrap-server localhost:2181 --topic test1
#或者
sh kafka-topics.sh --describe -bootstrap-server localhost:2181 --topic test1
9、修改Topic
./kafka-topics.sh --alter --bootstrap-server localhost:2181 --topic test1 --partitions 1
#或者
sh kafka-topics.sh --alter --bootstrap-server localhost:2181 --topic test1 --partitions 1
10、删除Topic
./kafka-topics.sh --delete -bootstrap-server localhost:2181 --topic test1
#或者
sh kafka-topics.sh --delete -bootstrap-server localhost:2181 --topic test1
11、创建一个生产者(可选):
./kafka-console-producer.sh --broker-list localhost:9092 --topic test1
#或者
sh kafka-console-producer.sh --broker-list localhost:9092 --topic test1
12、启动一个消费者(可选):(./和sh都是mac或者Linux系统中执行的意思)
# 从头开始消费
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test1 --from-beginning
# 从某个指定的分区消费
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test1 --partition 1