2017-08-21 4 views
1

私はGCEでKubernetesを使用してクラスタ構成を持っています。私にはzookeeper用のポッドとKafka用のポッドがあります。飼育係がクラッシュして再起動されるまで、それが正常に働いていた、そしてそれはカフカポッドからの接続を拒否開始:それは完全に拒否ログがある zxid 0x1962630Zookeeperは古いクライアントからのKafka接続を拒否します

を見ているように、クライアント/10.4.4.58:52260のためのセッション要求を拒否

ここで:

2017-08-21 20:05:32,013 [myid:] - INFO [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnx[email protected]] - 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:[email protected]] - 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:[email protected]] - 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:[email protected]] - Closed socket connection for client /10.4.4.58:52260 (no session established for client) 

答えて

1

カフカは最後に見たzxidを覚えている動物園のセッションを維持しているためです。だから、飼い猫飼い主のサービスが下りて再び来ると、zkのzxidは小さな値から始まります。 ZKserverはカフカが大きなzxidを見たと思うので、それを拒否します。

カフカを再起動してください。

関連する問題