kafka常用命令

kafka常用命令

   张吉吉     2021年7月27日 22:12     119    

查看topic

./kafka-topics.sh              \

--zookeeper 192.168.15.6:2181  \

--list

 

创建topic

./kafka-topics.sh               \

 --zookeeper 192.168.15.6:2181  \

 --create                     \

 --replication-factor 3          \

 --partitions 3                 \

 --topic first

创建一个名为firsttopic

--zookeeper:指定zookeeper的地址

--create:创建

--replication-factor:创建几个副本

--partitions:创建几个分区

--topic:主题名

 

删除topic

首先需要server.properties中设置delete.topic.enable=true,重启

./kafka-topics.sh                \

--zookeeper 192.168.15.6:2181          \

--delete                     \

--topic second

 

查看topic的详情

./kafka-topics.sh                \

--zookeeper 192.168.15.6:2181           \

--describe                    \

--topic second

 

创建消费者

./kafka-console-producer.sh \

--broker-list localhost:9092 \

--topic first

 

创建生产者

./kafka-console-consumer.sh      \

--bootstrap-server localhost:9092  \

--topic first

 

 

 


文章评论

0

其他文章