{"action":"opened","issue":{"url":"https://api.github.com/repos/oleksiyk/kafka/issues/53","repository_url":"https://api.github.com/repos/oleksiyk/kafka","labels_url":"https://api.github.com/repos/oleksiyk/kafka/issues/53/labels{/name}","comments_url":"https://api.github.com/repos/oleksiyk/kafka/issues/53/comments","events_url":"https://api.github.com/repos/oleksiyk/kafka/issues/53/events","html_url":"https://github.com/oleksiyk/kafka/issues/53","id":151669267,"number":53,"title":"Message offset if error while processing messageSet","user":{"login":"gthx","id":373059,"avatar_url":"https://avatars.githubusercontent.com/u/373059?v=3","gravatar_id":"","url":"https://api.github.com/users/gthx","html_url":"https://github.com/gthx","followers_url":"https://api.github.com/users/gthx/followers","following_url":"https://api.github.com/users/gthx/following{/other_user}","gists_url":"https://api.github.com/users/gthx/gists{/gist_id}","starred_url":"https://api.github.com/users/gthx/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/gthx/subscriptions","organizations_url":"https://api.github.com/users/gthx/orgs","repos_url":"https://api.github.com/users/gthx/repos","events_url":"https://api.github.com/users/gthx/events{/privacy}","received_events_url":"https://api.github.com/users/gthx/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":0,"created_at":"2016-04-28T15:16:12Z","updated_at":"2016-04-28T15:16:12Z","closed_at":null,"body":"How should I handle failure while processing messages?\r\nIt seems client/lib uses offset of the last received message and not the latest committed offset.\r\nsee https://github.com/oleksiyk/kafka/blob/master/lib/base_consumer.js#L72\r\n\r\nIs this a bug or should it be handled by the application."}}