{"action":"created","issue":{"url":"https://api.github.com/repos/elodina/siesta/issues/32","repository_url":"https://api.github.com/repos/elodina/siesta","labels_url":"https://api.github.com/repos/elodina/siesta/issues/32/labels{/name}","comments_url":"https://api.github.com/repos/elodina/siesta/issues/32/comments","events_url":"https://api.github.com/repos/elodina/siesta/issues/32/events","html_url":"https://github.com/elodina/siesta/pull/32","id":130574769,"number":32,"title":"Purge leader cache","user":{"login":"yudai","id":33192,"avatar_url":"https://avatars.githubusercontent.com/u/33192?v=3","gravatar_id":"","url":"https://api.github.com/users/yudai","html_url":"https://github.com/yudai","followers_url":"https://api.github.com/users/yudai/followers","following_url":"https://api.github.com/users/yudai/following{/other_user}","gists_url":"https://api.github.com/users/yudai/gists{/gist_id}","starred_url":"https://api.github.com/users/yudai/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/yudai/subscriptions","organizations_url":"https://api.github.com/users/yudai/orgs","repos_url":"https://api.github.com/users/yudai/repos","events_url":"https://api.github.com/users/yudai/events{/privacy}","received_events_url":"https://api.github.com/users/yudai/received_events","type":"User","site_admin":false},"labels":[],"state":"closed","locked":false,"assignee":null,"milestone":null,"comments":4,"created_at":"2016-02-02T04:53:21Z","updated_at":"2016-02-04T21:39:43Z","closed_at":"2016-02-04T14:25:39Z","pull_request":{"url":"https://api.github.com/repos/elodina/siesta/pulls/32","html_url":"https://github.com/elodina/siesta/pull/32","diff_url":"https://github.com/elodina/siesta/pull/32.diff","patch_url":"https://github.com/elodina/siesta/pull/32.patch"},"body":"Hi,\r\n\r\nI encountered an issue that go_kafka_client sometimes keeps outputting messages like below forever, when I shutdown one of the brokers of a 3-node cluster. \r\n\r\n```\r\n2016-02-02/01:54:12 [WARN] [ConsumerFetcherRoutine-0548e355-d927-bf25-a18f-57b6142b5e9f-0] Got a metadata out of fetch error for topic <topic_name>, partition 0: You've just attempted to send messages to a replica that is not the leader for some partition. It indicates that the clients metadata is out of date.\r\n```\r\n\r\nI'm not sure if this error should be handled by go_kafka_client (by recreating fetchers who raised this error?), but anyway, tried writing a patch that refleshes cached leaders when the connector got an `ErrNotLeaderForPartition` error.\r\n\r\nIf this solution makes sense, I'll write some tests and update the PR."},"comment":{"url":"https://api.github.com/repos/elodina/siesta/issues/comments/180063681","html_url":"https://github.com/elodina/siesta/pull/32#issuecomment-180063681","issue_url":"https://api.github.com/repos/elodina/siesta/issues/32","id":180063681,"user":{"login":"yudai","id":33192,"avatar_url":"https://avatars.githubusercontent.com/u/33192?v=3","gravatar_id":"","url":"https://api.github.com/users/yudai","html_url":"https://github.com/yudai","followers_url":"https://api.github.com/users/yudai/followers","following_url":"https://api.github.com/users/yudai/following{/other_user}","gists_url":"https://api.github.com/users/yudai/gists{/gist_id}","starred_url":"https://api.github.com/users/yudai/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/yudai/subscriptions","organizations_url":"https://api.github.com/users/yudai/orgs","repos_url":"https://api.github.com/users/yudai/repos","events_url":"https://api.github.com/users/yudai/events{/privacy}","received_events_url":"https://api.github.com/users/yudai/received_events","type":"User","site_admin":false},"created_at":"2016-02-04T21:39:43Z","updated_at":"2016-02-04T21:39:43Z","body":"thanks!"}}