Authentifizierung fehlgeschlagen zk Session Timeout Problem

Question

Ich benutze Samuel Go-zookeeper und habe Begegnung "Authentifizierung fehlgeschlagen: zk: Sitzung wurde vom Server abgelaufen" Problem. Sobald dieses Problem auftritt, versucht es erneut, sich mit dem zoekeeper zu verbinden und wird ebenfalls erfolgreich verbunden. Aber das Problem ist, es wird wieder "Authentifizierung fehlgeschlagen" Problem oder schlägt fehl, die Verbraucher zu registrieren. Wenn die Verbindung erfolgreich hergestellt und authentifiziert wird, verbraucht der Verbraucher die Nachricht nie als "Derzeit registrierte Benutzer: 0" und dieser Prozess wird fortgesetzt, wenn ich meinen Client nicht manuell neu starte.

Was könnte das Problem und seine Lösung sein? Hier

ist das Protokoll:

[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

Ich habe nicht Samuels Go-zookeeper verwendet. Sie versuchen jedoch, eine Verbindung zum kafka-Server herzustellen und eine Verbindung herzustellen. Um dies zu erreichen, verwende ich samara, die einfach zu bedienen und zuverlässig ist.

Here einige Beispiele.