验证失败ZK会话超时问题

Question

我使用萨穆埃尔的中间人饲养员，并已遇到“验证失败：ZK：会话已被服务器过期”问题。一旦遇到这个问题，它会重新尝试重新连接到zookeeper，并成功连接。但问题是它再次得到“身份验证失败”问题或未能注册消费者。此外，如果连接成功并且已通过身份验证，则消费者不会将消息视为“当前注册的消费者：0”，并且此过程将继续，除非我手动重新启动客户端。

可能是什么问题及其解决方案？

这里是日志：

[Scheduler] 2016/05/15 04:49:20 structs.go:21: Recv loop terminated: err=read tcp 10.244.0.9:41810->10.0.30.4:2181: i/o timeout 
[Scheduler] 2016/05/15 04:49:24 structs.go:21: Send loop terminated: err=<nil> 
[Scheduler] 2016/05/15 04:49:26 structs.go:21: Connected to 10.0.30.4:2181 
[Scheduler] 2016/05/15 04:49:53 structs.go:21: Authentication failed: read tcp 10.244.0.9:43854->10.0.30.4:2181: i/o timeout 
[Scheduler] 2016/05/15 04:49:57 structs.go:21: Connected to 10.0.30.4:2181 
[Scheduler] 2016/05/15 04:50:25 structs.go:21: Authentication failed: read tcp 10.244.0.9:43863->10.0.30.4:2181: i/o timeout 
[Scheduler] 2016/05/15 04:50:32 structs.go:21: Connected to 10.0.30.4:2181 
[Scheduler] 2016/05/15 04:51:06 structs.go:21: Authentication failed: read tcp 10.244.0.9:43873->10.0.30.4:2181: i/o timeout 
[Scheduler] 2016/05/15 04:51:55 structs.go:21: Connected to 10.0.30.4:2181 
[Scheduler] 2016/05/15 04:52:08 structs.go:21: Authentication failed: zk: session has been expired by the server 
[Sarama] 2016/05/15 04:52:08 [controller/fa956f688354] Triggering rebalance due to consumer list change 
[Scheduler] 2016/05/15 04:52:10 structs.go:21: Connected to 10.0.30.4:2181 
[Scheduler] 2016/05/15 04:52:10 structs.go:21: Authenticated: id=95829041879007139, timeout=4000 
[Sarama] 2016/05/15 04:52:10 [controller/fa956f688354] Currently registered consumers: 0 
[Sarama] 2016/05/15 04:52:10 [controller/fa956f688354] topic :: Started topic consumer 
[Sarama] 2016/05/15 04:52:10 [controller/fa956f688354] topic :: Stopped topic consumer 
[Sarama] 2016/05/15 04:53:22 client/metadata fetching metadata for all topics from broker 10.0.30.4:9092 
[Sarama] 2016/05/15 05:03:23 client/metadata fetching metadata for all topics from broker 10.0.30.4:9092 
. 
. 
. 
[Sarama] 2016/05/15 04:53:22 client/metadata fetching metadata for all topics from broker 10.0.30.4:9092 

Answer 1

我没有使用过塞缪尔的Go-饲养员。但是，您正尝试连接到kafka服务器并与之建立连接。为了达到这个目的，我使用了易于使用且可靠的samara。

Here一些例子。