{"action":"created","issue":{"url":"https://api.github.com/repos/akka/reactive-kafka/issues/241","repository_url":"https://api.github.com/repos/akka/reactive-kafka","labels_url":"https://api.github.com/repos/akka/reactive-kafka/issues/241/labels{/name}","comments_url":"https://api.github.com/repos/akka/reactive-kafka/issues/241/comments","events_url":"https://api.github.com/repos/akka/reactive-kafka/issues/241/events","html_url":"https://github.com/akka/reactive-kafka/issues/241","id":180672936,"number":241,"title":"Loading offsets from external storage while keeping Kafka rebalancing functionality","user":{"login":"iamhatesz","id":615769,"avatar_url":"https://avatars.githubusercontent.com/u/615769?v=3","gravatar_id":"","url":"https://api.github.com/users/iamhatesz","html_url":"https://github.com/iamhatesz","followers_url":"https://api.github.com/users/iamhatesz/followers","following_url":"https://api.github.com/users/iamhatesz/following{/other_user}","gists_url":"https://api.github.com/users/iamhatesz/gists{/gist_id}","starred_url":"https://api.github.com/users/iamhatesz/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/iamhatesz/subscriptions","organizations_url":"https://api.github.com/users/iamhatesz/orgs","repos_url":"https://api.github.com/users/iamhatesz/repos","events_url":"https://api.github.com/users/iamhatesz/events{/privacy}","received_events_url":"https://api.github.com/users/iamhatesz/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":3,"created_at":"2016-10-03T15:38:26Z","updated_at":"2016-11-24T02:35:54Z","closed_at":null,"body":"Hi,\n\nI am writing an application using `plainPartitionedSource` and I am storing offsets in some external storage. Then, when rebalancing happens, I want to fetch stored offsets and start consuming from them. \n\nSo my code looks like this:\n\n``` scala\nConsumer.plainPartitionedSource(settings, topics)\n      .map {\n        case (topicPartition, source) =>\n          val startingOffset = OffsetManager.get(topicPartition)\n\n          // Start processing from given offset\n          // source.seek(startingOffset)\n\n          source.map...\n      }\n```\n\nOf course there's no such method like `seek` on the `source` object. So my question is: is there any option to leave partition assignment to Kafka and pass starting offsets at the same time?\n"},"comment":{"url":"https://api.github.com/repos/akka/reactive-kafka/issues/comments/262676976","html_url":"https://github.com/akka/reactive-kafka/issues/241#issuecomment-262676976","issue_url":"https://api.github.com/repos/akka/reactive-kafka/issues/241","id":262676976,"user":{"login":"graphex","id":78928,"avatar_url":"https://avatars.githubusercontent.com/u/78928?v=3","gravatar_id":"","url":"https://api.github.com/users/graphex","html_url":"https://github.com/graphex","followers_url":"https://api.github.com/users/graphex/followers","following_url":"https://api.github.com/users/graphex/following{/other_user}","gists_url":"https://api.github.com/users/graphex/gists{/gist_id}","starred_url":"https://api.github.com/users/graphex/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/graphex/subscriptions","organizations_url":"https://api.github.com/users/graphex/orgs","repos_url":"https://api.github.com/users/graphex/repos","events_url":"https://api.github.com/users/graphex/events{/privacy}","received_events_url":"https://api.github.com/users/graphex/received_events","type":"User","site_admin":false},"created_at":"2016-11-24T02:35:54Z","updated_at":"2016-11-24T02:35:54Z","body":"I can see a few use cases for this as well, plus exposing this sort of utility would help the consumer be generally easier to use. Exposing more of the kafka consumer's API would be a good thing."}}
{"actor":{"display_login":"graphex"}}