zoukankan      html  css  js  c++  java
  • Kafka自我学习3-Scalable

    1.After created the zookeeper cluster, we found all broker cluster topic can be find in zoo1, zoo2, zoo3.

    [root@zoo1 zookeeper]# /root/kafka/bin/kafka-topics.sh  --describe --zookeeper zoo1:2181
    Topic:my-replicated-topic    PartitionCount:1    ReplicationFactor:3    Configs:
        Topic: my-replicated-topic    Partition: 0    Leader: 1    Replicas: 2,0,1    Isr: 1
    Topic:test    PartitionCount:1    ReplicationFactor:1    Configs:
        Topic: test    Partition: 0    Leader: 1    Replicas: 1    Isr: 1
    Topic:test123    PartitionCount:1    ReplicationFactor:1    Configs:
        Topic: test123    Partition: 0    Leader: 1    Replicas: 1    Isr: 1
    [root@zoo1 zookeeper]# /root/kafka/bin/kafka-topics.sh  --describe --zookeeper zoo2:2181
    Topic:my-replicated-topic    PartitionCount:1    ReplicationFactor:3    Configs:
        Topic: my-replicated-topic    Partition: 0    Leader: 1    Replicas: 2,0,1    Isr: 1
    Topic:test    PartitionCount:1    ReplicationFactor:1    Configs:
        Topic: test    Partition: 0    Leader: 1    Replicas: 1    Isr: 1
    Topic:test123    PartitionCount:1    ReplicationFactor:1    Configs:
        Topic: test123    Partition: 0    Leader: 1    Replicas: 1    Isr: 1
    [root@zoo1 zookeeper]# /root/kafka/bin/kafka-topics.sh  --describe --zookeeper zoo3:2181
    Topic:my-replicated-topic    PartitionCount:1    ReplicationFactor:3    Configs:
        Topic: my-replicated-topic    Partition: 0    Leader: 1    Replicas: 2,0,1    Isr: 1
    Topic:test    PartitionCount:1    ReplicationFactor:1    Configs:
        Topic: test    Partition: 0    Leader: 1    Replicas: 1    Isr: 1
    Topic:test123    PartitionCount:1    ReplicationFactor:1    Configs:
        Topic: test123    Partition: 0    Leader: 1    Replicas: 1    Isr: 1

    2.Even we shutdown the zoo or any leader of zookeeper cluster, we can see the topic still can be access on other zoo server

    3.Zookeeper-shell

    [root@zoo1 zookeeper]# /root/kafka/bin/zookeeper-shell.sh zoo1:2181
    Connecting to zoo1:2181
    Welcome to ZooKeeper!
    JLine support is disabled
    
    WATCHER::
    
    WatchedEvent state:SyncConnected type:None path:null
    help
    ZooKeeper -server host:port cmd args
        stat path [watch]
        set path data [version]
        ls path [watch]
        delquota [-n|-b] path
        ls2 path [watch]
        setAcl path acl
        setquota -n|-b val path
        history 
        redo cmdno
        printwatches on|off
        delete path [version]
        sync path
        listquota path
        rmr path
        get path [watch]
        create [-s] [-e] path data acl
        addauth scheme auth
        quit 
        getAcl path
        close 
        connect host:port

     4.

  • 相关阅读:
    第 16 章 CSS 盒模型[下]
    第 16 章 CSS 盒模型[上]
    第 15 章 CSS 文本样式[下]
    第 15 章 CSS 文本样式[上]
    第 14 章 CSS 颜色与度量单位
    第 13 章 CSS 选择器[上]
    第 12 章 CSS 入门
    关于springboot上传文件报错:The temporary upload location ***is not valid
    Java Enum枚举 遍历判断 四种方式(包括 Lambda 表达式过滤)
    git命令-切换分支
  • 原文地址:https://www.cnblogs.com/oskb/p/9069043.html
Copyright © 2011-2022 走看看