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接收到这条消息的时间
Original: https://www.cnblogs.com/itfenqing/p/14616128.html
Author: rorshach
Title: kafka之topic
原创文章受到原创版权保护。转载请注明出处：https://www.johngo689.com/534015/
转载文章受原作者版权保护。转载请注明原作者出处！