如何检测无法访问的代理kafka并重新连接？

qoefvg9y 于 2021-06-06 发布在 Kafka

关注(0)|答案(1)|浏览(254)

方案：2 broker-2 hosts java clients-org.apache.kafka.clients.producer.kafkaproducer或org.apache.kafka.clients.consumer.kafkaconsumer bootsrap servers属性包含2个ip地址（2个代理）zookeeper-分布式协调器
构造函数org.apache.kafka.clients.clientutil的调用方法#parseAndValidateAddresss只检查没有验证示例的网络服务器（检查损坏的状态服务器或不启动）

Java apache-kafka apache-zookeeper

来源：https://stackoverflow.com/questions/50213407/how-to-detect-unreachable-brokers-kafka-and-reconnect

1条答案

按热度按时间

svdrlsy41#

默认情况下，zookeeper会跟踪所有连接的节点和可访问的代理。您可以查询zk来查看当前连接了哪些节点。


# Connect to ZooKeeper

bin/zookeeper-shell.sh  localhost:2181
Connecting to localhost:2181
Welcome to ZooKeeper!
JLine support is disabled

WATCHER::

WatchedEvent state:SyncConnected type:None path:null
    >> ls /brokers/ids
        [1, 2, 3]
    >> ls /brokers/topics
        [myTopic, __consumer_offsets]
    >> get /brokers/ids/0
    Node does not exist: /brokers/ids/0
    >> get /brokers/ids/1
    {"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT","SSL":"SSL"},"endpoints":["PLAINTEXT://172.31.4.17:9092","SSL://18.216.252.106:9093"],"jmx_port":9999,"host":"172.31.4.17","timestamp":"1522349056258","port":9092,"version":4}
    cZxid = 0x3000005f3
    ctime = Thu Mar 29 18:44:16 UTC 2018
    mZxid = 0x3000005f3
    mtime = Thu Mar 29 18:44:16 UTC 2018
    pZxid = 0x3000005f3
    cversion = 0
    dataVersion = 0
    aclVersion = 0
    ephemeralOwner = 0x2625d127c0b0003
    dataLength = 234
    numChildren = 0

赞(0）回复(0）举报 2021-06-07

我来回答

如何检测无法访问的代理kafka并重新连接？

1条答案

相关问题

热门标签

最新问答