zoukankan      html  css  js  c++  java
  • Kafka 命令行操作

    创建 topic

    [root@localhost kafka]# bin/kafka-topics.sh --zookeeper 192.168.1.102:2181 --create --replication-factor 3 --partitions 1 --topic first

    选项说明:

    • topic 定义 topic 名
    • replication-factor 定义副本数
    • partitions 定义分区数 

    查看当前服务器中的所有 topic

    [root@localhost kafka]# bin/kafka-topics.sh --zookeeper 192.168.1.102:2181 --list

    删除 topic

    需要 server.properties 中设置 delete.topic.enable=true 否则只是标记删除。 

    [root@localhost kafka]# bin/kafka-topics.sh --zookeeper 192.168.1.102:2181 --delete --topic first

    查看某个 Topic 的详情

    [root@localhost kafka]# bin/kafka-topics.sh --zookeeper 192.168.1.102:2181 --describe --topic first

    Topic:first    PartitionCount:1    ReplicationFactor:3    Configs:
        Topic: first    Partition: 0    Leader: 0    Replicas: 0,2,1    Isr: 0

    发送消息和消费消息的命令一般由API操作,这里不作介绍

  • 相关阅读:
    [solr]
    [solr]
    [Linux] CentOS 加入开机启动
    [Linux] VirtualBox
    [Eclipse]
    [JBoss]
    [solr]
    [solr]
    [solr]
    [solr]
  • 原文地址:https://www.cnblogs.com/weianlai/p/14589299.html
Copyright © 2011-2022 走看看