动物园管理员拒绝卡夫卡与老客户的联系。

Question

我在GCE上使用Kubernetes进行了集群配置，为动物园管理员和卡夫卡提供了一个吊舱；它在动物饲养员崩溃和重新启动之前正常工作，并开始拒绝从kafka吊舱连接：

拒绝客户端/10.4.4.58:52260的会话请求，正如它所看到的zxid 0x1962630

完整的拒绝日志如下：

2017-08-21 20:05:32,013 [myid:] - INFO  [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxnFactory@192] - Accepted socket connection from /10.4.4.58:52260
2017-08-21 20:05:32,013 [myid:] - WARN  [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:ZooKeeperServer@882] - Connection request from old client /10.4.4.58:52260; will be dropped if server is in r-o mode
2017-08-21 20:05:32,013 [myid:] - INFO  [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:ZooKeeperServer@901] - Refusing session request for client /10.4.4.58:52260 as it has seen zxid 0x1962630 our last zxid is 0xab client must try another server
2017-08-21 20:05:32,013 [myid:] - INFO  [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxn@1008] - Closed socket connection for client /10.4.4.58:52260 (no session established for client)

Answer 1

因为卡夫卡保持了一个动物园管理员会话，它记得它看到的最后一个zxid。所以当饲养员下楼再来的时候，zk的zxid从一个较小的值开始。ZKserver认为卡夫卡看到了更大的zxid，所以它拒绝了。

试着重启卡夫卡。

Answer 2

作为记录，我遇到了这个问题，我所有的卡夫卡都被关闭了。

但是，我的卡夫卡经理还在听动物园管理员讲话。关掉它解决了这个问题。

Answer 3

与“广生左”的答案有关。步骤

1. 停止任何剩余的动物园管理员实例- zookeeper-server-stop.bat
2. 启动一个新的动物园管理员- zookeeper-server-start.bat .\config\zookeeper.properties这就可以了