1、Kafka2.2.1操作命令

梦里梦外; 2022-10-18 11:29 167阅读 0赞

**1 没有关注的小伙伴可以在微信搜索框中搜索微信公众号： **

**3分钟秒懂大数据**，然后点击关注，回复 **kafka** ** **即可免费领取 kafka\_2.12-2.2.1.tgz 软件安装包！！！  
![图片][7879bd17e5c4cae2fc9d2dfbfc28bb88.png]

**（1）启停命令**

cd /usr/lib/LOCALCLUSTER/kafka_2.11-2.2.0/bin
      
      nohup ./kafka-server-start.sh ../config/server.properties &

**（2）  kafka停止命令**

cd /usr/lib/LOCALCLUSTER/kafka_2.11-2.2.0/bin
    
    ./kafka-server-stop.sh ../config/server.properties &

**（3）操作命令**

1、查看当前服务器中的所有topic全部是在kafka中的bin目录下执行
    
    ./kafka-topics.sh --list --bootstrap-server 192.168.244.161:9092
    
    2、创建topic
    
    ./kafka-topics.sh --create --bootstrap-server 192.168.244.161:9092 --replication-factor 1 --partitions 3 --topic model_topic
    
    3、删除topic
    
    ./kafka-topics.sh --delete --bootstrap-server 192.168.244.161:9092 --topic order  
    
    4、通过shell命令发送消息
    
    ./kafka-console-producer.sh --broker-list 192.168.244.161:9092 --topic test
      
      
     5、通过shell消费消息
    
    ./kafka-console-consumer.sh --bootstrap-server 192.168.244.161:9092 --from-beginning --topic model_topic
     
     
    6、查看消费位置
    
    sh kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --bootstrap-server 10.3.69.161:9092 --group testGroup
    
    7、查看某个Topic的详情
    
    sh kafka-topics.sh --topic test --describe --bootstrap-server 10.3.69.161:9092 
     
    8 查看topic中的offset起始条数
    ./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 10.3.69.161:9092 --topic lightgbm494_model --time -2
    
    9 查看topic中的offset终止条数 
    ./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 10.3.69.161:9092 --topic lightgbm494_model --time -1

[7879bd17e5c4cae2fc9d2dfbfc28bb88.png]: /images/20221014/1876f95ba2194d99839fefd3e2c48499.png