kafka命令行的管理使用

Posted 2021-06-20 Tenic

• 1、创建topic

  • 使用 kafka-topics.sh脚本

    kafka-topics.sh --create --partitions 3 --replication-factor 2 --topic test --zookeeper hadoop01:2181,hadoop02:2181,hadoop03:2181
    

• 2、查询所有的topic

  • 使用 kafka-topics.sh脚本

    kafka-topics.sh --list --zookeeper hadoop01:2181,hadoop02:2181,hadoop03:2181
    

• 3、查看topic的描述信息

  • 使用 kafka-topics.sh脚本

    kafka-topics.sh --describe --topic test --zookeeper hadoop01:2181,hadoop02:2181,hadoop03:2181
    

• 4、删除topic

  • 使用 kafka-topics.sh脚本

    kafka-topics.sh --delete --topic test --zookeeper hadoop01:2181,hadoop02:2181,hadoop03:2181
    

• 5、模拟生产者写入数据到topic中

  • 使用 kafka-console-producer.sh 脚本

    kafka-console-producer.sh --broker-list hadoop01:9092,hadoop02:9092,hadoop03:9092 --topic test 
    

• 6、模拟消费者拉取topic中的数据

  • 使用 kafka-console-consumer.sh 脚本

    kafka-console-consumer.sh --zookeeper hadoop01:2181,hadoop02:2181,hadoop03:2181 --topic test --from-beginning
    或者
    kafka-console-consumer.sh --bootstrap-server hadoop01:9092,hadoop02:9092,hadoop03:9092 --topic test --from-beginning