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.

  • 相关阅读:
    Windows解决端口占用
    Oracle数字格式化
    Windows生成项目目录结构
    IDEA激活教程
    Windows搭建SMB服务
    在右键新建菜单中添加新项目
    Fastjson1.2.47反序列化+环境搭建+漏洞复现
    nmap常用命令及端口
    Shiro反序列化复现
    CVE-2020-0796漏洞复现
  • 原文地址:https://www.cnblogs.com/oskb/p/9069043.html
Copyright © 2011-2022 走看看