#####################
Kafka2.x命令
#####################
创建topic
kafka-topics.sh --zookeeper n11hdp01:2181,n12hdp02:2181,n13hdp03:2181/kafka --create --replication-factor 3 --partitions 3 --topic event_oper_input
kafka-topics.sh --zookeeper n11hdp01:2181,n12hdp02:2181,n13hdp03:2181/kafka --create --replication-factor 3 --partitions 3 --topic event_oper_output
查看当前所有topic
kafka-topics.sh --zookeeper n11hdp01:2181,n12hdp02:2181,n13hdp03:2181/kafka --list
删除topic
kafka-topics.sh --zookeeper n11hdp01:2181,n12hdp02:2181,n13hdp03:2181/kafka --delete --topic event_oper
创建生产者
kafka-console-producer.sh --broker-list n11hdp01:6667,n12hdp02:6667,n13hdp03:6667 --topic event_oper_input
创建消费者
kafka-console-consumer.sh --bootstrap-server n11hdp01:6667,n12hdp02:6667,n13hdp03:6667 --topic event_oper
kafka-console-consumer.sh --bootstrap-server n11hdp01:6667,n12hdp02:6667,n13hdp03:6667 --topic event_oper_output
查看topic详情
kafka-topics.sh --zookeeper n11hdp01:2181,n12hdp02:2181,n13hdp03:2181/kafka --describe --topic event_oper
修改分区数
kafka-topics.sh --zookeeper n11hdp01:2181,n12hdp02:2181,n13hdp03:2181/kafka --alter --topic event_oper --partitions 6
#####################
Kafka3.x命令
#####################
查看所有topic
./kafka-topics.sh --bootstrap-server 192.168.10.100:9092 --list
创建topic
./kafka-topics.sh --bootstrap-server 192.168.10.100:9092 --create --replication-factor 1 --partitions 1 --topic test
查看topic详情
./kafka-topics.sh --bootstrap-server 192.168.10.100:9092 --describe --topic test
修改分区数(注意:分区数只能增加,不能减少)
./kafka-topics.sh --bootstrap-server 192.168.10.100:9092 --alter --topic test --partitions 3
删除topic
./kafka-topics.sh --bootstrap-server 192.168.10.100:9092 --delete --topic test
启动生产者
./kafka-console-producer.sh --bootstrap-server 192.168.10.100:9092 --topic test
启动消费者
./kafka-console-consumer.sh --bootstrap-server 192.168.10.100:9092 --topic test文章来源:https://www.toymoban.com/news/detail-706075.html
把主题中所有的数据都读取出来(包括历史数据)
./kafka-console-consumer.sh --bootstrap-server 192.168.10.100:9092 --from-beginning --topic test文章来源地址https://www.toymoban.com/news/detail-706075.html
到了这里,关于kafka2.x和3.x相关命令的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!