動物園管理員或卡夫卡連接時出現錯誤，顯示卡祖笛:: VersionNotSupported錯誤

我使用卡夫卡和飼養員，與他們之間建立連接，但是當我嘗試創建新卡夫卡::消費者動物園管理員或卡夫卡連接時出現錯誤，顯示卡祖笛:: VersionNotSupported錯誤

的連接越來越再度回落，並再次

ZOOKEEPER = '127.0.0.1:2181' 
CLIENT_ID = '************' 
TOPICS = ['*****'] 

@consumer = Kafka::Consumer.new(CLIENT_ID, TOPICS, zookeeper: ZOOKEEPER, logger: nil)

我還檢查了動物園管理員和卡夫卡日誌文件，並得到了當我嘗試創建新的卡夫卡::消費者

卡夫卡登錄我的卡夫卡到動物園管理員連接斷開：

... 
    [2016-03-04 16:14:47,553] INFO [Group Metadata Manager on Broker 0]: Removed 0 expired offsets in 0 milliseconds. (kafka.coordinator.GroupMetadataManager) 
    [2016-03-04 16:16:11,419] INFO Unable to read additional data from server sessionid 0x1533ff65f850003, likely server has closed socket, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) 
    [2016-03-04 16:16:11,520] INFO zookeeper state changed (Disconnected) (org.I0Itec.zkclient.ZkClient) 
    [2016-03-04 16:16:13,128] INFO Opening socket connection to server localhost/127.0.0.1:2181. Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeeper.ClientCnxn) 
    [2016-03-04 16:16:13,129] WARN Session 0x1533ff65f850003 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) 
    java.net.ConnectException: Connection refused 
    at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) 
    at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717) 
    at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361) 
    at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1081) 
    ...

動物園管理員登錄：

... 
2016-04-04 10:30:30,577 - INFO [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:[email protected]] - Client attempting to establish new session at /127.0.0.1:51152 
2016-04-04 10:30:30,579 - INFO [SyncThread:0:[email protected]] - Creating new log file: log.725 
2016-04-04 10:30:30,668 - INFO [SyncThread:0:[email protected]] - Established session 0x153df9fc2a70000 with negotiated timeout 6000 for client /127.0.0.1:51152 
2016-04-04 10:30:31,714 - INFO [ProcessThread(sid:0 cport:-1)::[email protected]] - Got user-level KeeperException when processing sessionid:0x153df9fc2a70000 type:delete cxid:0x26 zxid:0x728 txntype:-1 reqpath:n/a Error Path:/admin/preferred_replica_election Error:KeeperErrorCode = NoNode for /admin/preferred_replica_election 
2016-04-04 10:30:31,883 - INFO [ProcessThread(sid:0 cport:-1)::[email protected]] - Got user-level KeeperException when processing sessionid:0x153df9fc2a70000 type:create cxid:0x2d zxid:0x729 txntype:-1 reqpath:n/a Error Path:/brokers Error:KeeperErrorCode = NodeExists for /brokers 
...

安裝寶石

使用IONE 1.2.3
使用JSON 1.8.3
使用雷神0.19.1
使用飼養員1.4。 11
使用poseidon 0.0.5
使用捆綁1.11.2
使用Cassandra的驅動程序2.1.5
使用卡祖笛，紅寶石0.4.0
使用卡夫卡消費0.1.2

我正好沒能得到哪裏出了問題版本

四處錯誤：

~/../kazoo-ruby-0.4.0/lib/kazoo/broker.rb:83:in `from_json': Kazoo::VersionNotSupported 
~/../kazoo-ruby-0.4.0/lib/kazoo/cluster.rb:38:in `block (3 levels) in brokers'

來源

2016-03-22 Ravin Gupta

得到了解決，I W因爲使用卡夫卡版本0.9.0.1或0.8.0測試版正在創建一些版本問題。現在，我下載並安裝了適用於我的scala 2.11版本的Kafka 0.8.2.2。

來源

2016-04-04 06:30:38

動物園管理員或卡夫卡連接時出現錯誤，顯示卡祖笛:: VersionNotSupported錯誤

回答

相關問題