#####################
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
把主题中所有的数据都读取出来(包括历史数据)
./kafka-console-consumer.sh --bootstrap-server 192.168.10.100:9092 --from-beginning --topic test