{"action":"closed","issue":{"url":"https://api.github.com/repos/pipelinedb/pipeline_kafka/issues/30","repository_url":"https://api.github.com/repos/pipelinedb/pipeline_kafka","labels_url":"https://api.github.com/repos/pipelinedb/pipeline_kafka/issues/30/labels{/name}","comments_url":"https://api.github.com/repos/pipelinedb/pipeline_kafka/issues/30/comments","events_url":"https://api.github.com/repos/pipelinedb/pipeline_kafka/issues/30/events","html_url":"https://github.com/pipelinedb/pipeline_kafka/issues/30","id":175571921,"number":30,"title":"HA consumer","user":{"login":"derekjn","id":384666,"avatar_url":"https://avatars.githubusercontent.com/u/384666?v=3","gravatar_id":"","url":"https://api.github.com/users/derekjn","html_url":"https://github.com/derekjn","followers_url":"https://api.github.com/users/derekjn/followers","following_url":"https://api.github.com/users/derekjn/following{/other_user}","gists_url":"https://api.github.com/users/derekjn/gists{/gist_id}","starred_url":"https://api.github.com/users/derekjn/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/derekjn/subscriptions","organizations_url":"https://api.github.com/users/derekjn/orgs","repos_url":"https://api.github.com/users/derekjn/repos","events_url":"https://api.github.com/users/derekjn/events{/privacy}","received_events_url":"https://api.github.com/users/derekjn/received_events","type":"User","site_admin":false},"labels":[],"state":"closed","locked":false,"assignee":null,"assignees":[],"milestone":{"url":"https://api.github.com/repos/pipelinedb/pipeline_kafka/milestones/1","html_url":"https://github.com/pipelinedb/pipeline_kafka/milestones/0.9.5","labels_url":"https://api.github.com/repos/pipelinedb/pipeline_kafka/milestones/1/labels","id":1956153,"number":1,"title":"0.9.5","description":"","creator":{"login":"derekjn","id":384666,"avatar_url":"https://avatars.githubusercontent.com/u/384666?v=3","gravatar_id":"","url":"https://api.github.com/users/derekjn","html_url":"https://github.com/derekjn","followers_url":"https://api.github.com/users/derekjn/followers","following_url":"https://api.github.com/users/derekjn/following{/other_user}","gists_url":"https://api.github.com/users/derekjn/gists{/gist_id}","starred_url":"https://api.github.com/users/derekjn/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/derekjn/subscriptions","organizations_url":"https://api.github.com/users/derekjn/orgs","repos_url":"https://api.github.com/users/derekjn/repos","events_url":"https://api.github.com/users/derekjn/events{/privacy}","received_events_url":"https://api.github.com/users/derekjn/received_events","type":"User","site_admin":false},"open_issues":3,"closed_issues":3,"state":"open","created_at":"2016-08-22T19:42:57Z","updated_at":"2016-09-27T21:43:58Z","due_on":null,"closed_at":null},"comments":0,"created_at":"2016-09-07T18:19:29Z","updated_at":"2016-09-27T21:43:58Z","closed_at":"2016-09-27T21:43:58Z","body":"We'll probably want to store offsets in Kafka. Ideally redundant consumers can all be running in parallel, and one will take over when another one fails. Can we leverage Kafka/ZK for detecting a failed consumer?"}}
{"actor":{"display_login":"usmanm"}}