一、启动
- 后台启动
nohup sh bin/kafka-server-start.sh config/server.properties &
- 守护进程启动【推荐】
sh sh bin/kafka-server-start.sh -daemon config/server.properties
二、topic 创建
- topic创建
sh bing/kafka-topics.sh
--zookeeper # zk的ip地址列表
--create #创建命令
--topic #后跟topic名
--partitions #分区数
--replication-factor # 副本数
sh bin/kafka-topics.sh --create --topic test1 --zookeeper localhost:2181 --partitions 5 --replication-factor 1
- topic列表查看
sh bin/kafka-topics.sh --list --zookeeper localhost:2181
- 查看topic的描述信息
sh bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test1
- 查看topic的过期时间配置
sh bin/kafka-configs.sh --zookeeper localhost:2181 --describe --entity-name test1 --entity-type topics
三、topic 生产数据
Todo
