本文介绍下kafka部分配置 启动以及部分命令测试
首先下载zookeeper与kafka 选择版本下载即可
地址如下 zookeeper下载地址 kafka下载地址
下载完成后需要进行简单配置
zookeeper配置与启动见另一篇文章
kafka配置
1
2
3
4
5
6
7
| ###进入config目录 修改server.properties文件
# 表示broker的id 必须为不重复的数字
broker.id=0
# 此处参数名虽为日志 但是其实是数据保存路径 日志文件夹(logs)会自动生成
log.dirs=D:/MyWeb/kafka_2.13-2.5.0/tmp/kafka-logs
# 配置注册中心地址 端口
zookeeper.connect=127.0.0.1:2181
|
kafka 启动
windows
1
2
| ##首先需要进入kafka目录
.\bin\kafka-server-start.sh -daemon .\config\server.properties
|
linux
1
2
| ##首先需要进入kafka目录
./bin/kafka-server-start.sh -daemon ./config/server.properties
|
以下在windows环境测试
创建topic
1
2
3
4
5
6
7
| 参数说明:
--topic 主题 设置主题名称 不可重复
--zookeeper zookeeper地址
--partiotions 分区数 默认是1(配置在server.properties中)
--replication-factor 副本数 不得多于broker的个数 默认值是1
--create 指明为创建
.\bin\windows\kafka-topics.bat --topic oiyou --zookeeper 127.0.0.1:2181 --partitions 2 --replication-factor 1 --create
|
查看topic列表
1
2
3
4
| 参数说明
--zookeeper 指定zookeeper地址
--list 指明是查询列表
.\bin\windows\kafka-topices.bat --zookeeper 127.0.0.1:2181 --list
|
查看单个topic
1
2
3
| 参数说明
--describe 详情
.\bin\windows\kafka-topics.bat --zookeeper 127.0.0.1:2181 --topic oiyou --describe
|
增加topic的partition
1
2
| --alter 表明修改
.\bin\windows\kafka-topics.bat --zookeeper 127.0.0.1:2181 --alter --topic oiyou --partitions 5
|
删除topic
1
2
| --delete 表明删除(删除的话需要删除zookeeper和kafka相关数据)
.\bin\windows\kafka-topics.bat --zookeeper 127.0.0.1:2181 --topic me --delete
|
发送消息
1
2
| --broker-list 127.0.0.1:9092 需要使用kafka配置的端口 默认是9092
.\bin\windows\kafka-console-producer.bat --broker-list 127.0.0.1:9092 --topic me
|
消费消息 从头开始
1
2
3
4
5
| 参数说明
--
--bootstrap-server 指定kafka地址 用于消费
--from-beginning 从头开始
.\bin\windows\kafka-console-consumer.bat --bootstrap-server 127.0.0.1:9092 --topic oiyou --from-beginning
|
从尾部消费
1
| .\bin\windows\kafka-console-consumer.bat --bootstrap-server 127.0.0.1:9091 --topic oiyou --offset latest --partition 0
|
