{"action":"created","issue":{"url":"https://api.github.com/repos/stealthly/go_kafka_client/issues/159","labels_url":"https://api.github.com/repos/stealthly/go_kafka_client/issues/159/labels{/name}","comments_url":"https://api.github.com/repos/stealthly/go_kafka_client/issues/159/comments","events_url":"https://api.github.com/repos/stealthly/go_kafka_client/issues/159/events","html_url":"https://github.com/stealthly/go_kafka_client/pull/159","id":106777465,"number":159,"title":"Fix zookeeper event watching, subscription, reconnection","user":{"login":"serejja","id":1804417,"avatar_url":"https://avatars.githubusercontent.com/u/1804417?v=3","gravatar_id":"","url":"https://api.github.com/users/serejja","html_url":"https://github.com/serejja","followers_url":"https://api.github.com/users/serejja/followers","following_url":"https://api.github.com/users/serejja/following{/other_user}","gists_url":"https://api.github.com/users/serejja/gists{/gist_id}","starred_url":"https://api.github.com/users/serejja/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/serejja/subscriptions","organizations_url":"https://api.github.com/users/serejja/orgs","repos_url":"https://api.github.com/users/serejja/repos","events_url":"https://api.github.com/users/serejja/events{/privacy}","received_events_url":"https://api.github.com/users/serejja/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":4,"created_at":"2015-09-16T13:48:20Z","updated_at":"2015-09-18T08:28:33Z","closed_at":null,"pull_request":{"url":"https://api.github.com/repos/stealthly/go_kafka_client/pulls/159","html_url":"https://github.com/stealthly/go_kafka_client/pull/159","diff_url":"https://github.com/stealthly/go_kafka_client/pull/159.diff","patch_url":"https://github.com/stealthly/go_kafka_client/pull/159.patch"},"body":""},"comment":{"url":"https://api.github.com/repos/stealthly/go_kafka_client/issues/comments/141380467","html_url":"https://github.com/stealthly/go_kafka_client/pull/159#issuecomment-141380467","issue_url":"https://api.github.com/repos/stealthly/go_kafka_client/issues/159","id":141380467,"user":{"login":"serejja","id":1804417,"avatar_url":"https://avatars.githubusercontent.com/u/1804417?v=3","gravatar_id":"","url":"https://api.github.com/users/serejja","html_url":"https://github.com/serejja","followers_url":"https://api.github.com/users/serejja/followers","following_url":"https://api.github.com/users/serejja/following{/other_user}","gists_url":"https://api.github.com/users/serejja/gists{/gist_id}","starred_url":"https://api.github.com/users/serejja/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/serejja/subscriptions","organizations_url":"https://api.github.com/users/serejja/orgs","repos_url":"https://api.github.com/users/serejja/repos","events_url":"https://api.github.com/users/serejja/events{/privacy}","received_events_url":"https://api.github.com/users/serejja/received_events","type":"User","site_admin":false},"created_at":"2015-09-18T08:28:33Z","updated_at":"2015-09-18T08:28:33Z","body":"Hey John,\r\n\r\nI've tried both quiet cluster and running traffic (approx. 5k dummy msg/sec) and still can't reproduce that. Not sure what I'm doing wrong :)\r\n\r\nRegarding intercepting panics I think we could add something like a PanicHandler (or whatever would we call it) to the ConsumerConfig with the default implementation that would panic as it is now. This way we wouldn't break any existing clients AND would give the ability to handle abnormal situations like this more or less gracefully.\r\n\r\nI think I'll create a separate PR with this behavior and let you know.\r\n\r\nThanks!"}}