kafka之topic

kafka

一.列出topic
./kafka-topics.sh --list --zookeeper ZooKeeper的任意一个节点或者全部的IP:Port/kafka

二.查看某一topic详细信息
./kafka-topics.sh --zookeeper localhost:2181 --topic topic名称 --describe

三.创建topic
./kafka-topics.sh --create --topic topic名称 --partitions 分区数 --replication-factor 备份数 --zookeeper ZooKeeper的任意一个节点或者全部的IP:Port/kafka

四.修改topic
./kafka-topics.sh --alter --topic topic名称 --config 配置项=配置值
如:
./kafka-topics.sh -zookeeper localhost:2181 --topic 主题名称 --alter --config message.timestamp.type=LogAppendTime

#设置时间戳类型为broker接收到这条消息的时间

可视化工具:Kafdrop

2021-09-21
2021-05-05
2021-05-12
2021-06-06
2021-11-05
2021-11-30
2021-07-07