• Linux——kafka常用命令


    一、前言

    多多点赞,会变好看!

    多多留言,会变有钱!

    二、Kafka的常用命令包括:

    1. 启动Zookeeper服务

    前台启动:

    ./bin/zookeeper-server-start.sh config/zookeeper.properties

    后台启动:

    ./bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

    2. 停止Zookeeper服务

    ./bin/zookeeper-server-stop.sh

    3. 启动Kafka服务

    前台启动:

    ./bin/kafka-server-start.sh config/server.properties

    后台启动:

    ./bin/kafka-server-start.sh -daemon config/server.properties

    4. 停止Kafka服务

    ./bin/kafka-server-stop.sh

    5. 创建主题

    创建一个叫demo-topic的主题(topic),有两个分区,每个分区3个副本,同时指定该主题的消息保留时长(72小时):

    ./bin/kafka-topics.sh --zookeeper(host:port) --create --topic demo-topic --replication-factor 3 --partitions 2 --topic test --retention-hours 72

    单机创建主题

    bin/kafka-topics.sh --create --replication-factor 1 --partitions 1 --topic test --bootstrap-server localhost:9092

    6. 查看所有主题

    ./bin/kafka-topics.sh --list --bootstrap-server localhost:9092

    7. 生产消息

    ./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

    8. 消费消息

    ./bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

     没有zookeeper:

    ./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

     9. 查看某一topic具体信息: 

    ./bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test

    没有zookeeper:

    ./bin/kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic test 

    三、组合启动/停止

    启动服务

    1. #/bin/bash
    2. #启动zookeeper
    3. bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
    4. #启动kafka
    5. bin/kafka-server-start.sh -daemon config/server.properties

    停止服务

    1. #/bin/bash
    2. #停止zookeeper
    3. bin/kafka-server-stop.sh
    4. #停止kafka
    5. bin/zookeeper-server-stop.sh

  • 相关阅读:
    Centos7安装部署openLDAP并springboot集成openLDAP
    JS 的 substr() 方法
    面试 Java 并发编程八股文十问十答第四期
    【Python编程】五、列表与元组
    axios封装
    性能调优——小小的log大大的坑
    每天几道Java面试题:IO流(第五天)
    Flutter 剪裁(Clip)
    C++核心编程:P15->STL----常用容器(上)
    基于java+SpringBoot+HTML+Mysql宠物医院网站
  • 原文地址:https://blog.csdn.net/qq_26230421/article/details/132979081