创建主题
bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic xxx --partitions 2 --replication-factor 1
zookeeper:服务的地址 create:创建主题 topic:主题名称 partitions:当前主题所要几个分区 replication-factor:指定副本的数(分布在不同节点,不能超过总节点数)
查看所有主题
bin/kafka-topics.sh --zookeeper localhost:2181 --list
查看主题详情
bin/kafak-topics.sh --zookeeper localhost:2181 --describe --topic xx
删除主题
如果delete.topic.enable=true 直接彻底删除topic。
则delete.topic.enable=false 如果当前topic没有使用过并没有传输过信息,可以彻底删除。如果当前topic使用过即有过传输信息,就不会真正的删除(topic只是把这个topic标记为删除),重启kafka server后删除。
bin/kafak-topics.sh --delete --zookeeper localhost:2181 --topic xxx
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)