{"action":"created","issue":{"url":"https://api.github.com/repos/confluentinc/kafka-rest-node/issues/14","repository_url":"https://api.github.com/repos/confluentinc/kafka-rest-node","labels_url":"https://api.github.com/repos/confluentinc/kafka-rest-node/issues/14/labels{/name}","comments_url":"https://api.github.com/repos/confluentinc/kafka-rest-node/issues/14/comments","events_url":"https://api.github.com/repos/confluentinc/kafka-rest-node/issues/14/events","html_url":"https://github.com/confluentinc/kafka-rest-node/issues/14","id":134320191,"number":14,"title":"Ability to commit offset of consumer","user":{"login":"lironess","id":4243338,"avatar_url":"https://avatars.githubusercontent.com/u/4243338?v=3","gravatar_id":"","url":"https://api.github.com/users/lironess","html_url":"https://github.com/lironess","followers_url":"https://api.github.com/users/lironess/followers","following_url":"https://api.github.com/users/lironess/following{/other_user}","gists_url":"https://api.github.com/users/lironess/gists{/gist_id}","starred_url":"https://api.github.com/users/lironess/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/lironess/subscriptions","organizations_url":"https://api.github.com/users/lironess/orgs","repos_url":"https://api.github.com/users/lironess/repos","events_url":"https://api.github.com/users/lironess/events{/privacy}","received_events_url":"https://api.github.com/users/lironess/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":4,"created_at":"2016-02-17T15:56:45Z","updated_at":"2016-12-19T20:08:25Z","closed_at":null,"body":"Hi.\nThere is an option for the Kafka Rest Proxy to commit offsets as you can see [here](http://docs.confluent.io/2.0.0/kafka-rest/docs/api.html#post--consumers-%28string-group_name%29-instances-%28string-instance%29-offsets).\nI want this options to be available for a consumer i created.\nsomething like :\n\n``` javascript\nvar kafkaRest = require('kafka-rest');\n\nvar kafka = new kafkaRest({ url: restProxyServerUrl });\n\nkafka.consumer(myConsumerGroup).join(\n  { 'format': `avro`, 'auto.offset.reset': `smallest`, `socket.timeout.ms`: `20000` }\n  , function(error, consumer) {\n    var listener = consumer.subscribe(topic);\n\n    listener.on(`data`, function(messages) {\n      consumer.commitOffset();\n    });\n  });\n```\n\nnotice the `consumer.commitOffset();` - it is like making a HTTP request to [this](http://docs.confluent.io/2.0.0/kafka-rest/docs/api.html#post--consumers-%28string-group_name%29-instances-%28string-instance%29-offsets) with the consumerGroup and raw name from the instance.\n"},"comment":{"url":"https://api.github.com/repos/confluentinc/kafka-rest-node/issues/comments/268064893","html_url":"https://github.com/confluentinc/kafka-rest-node/issues/14#issuecomment-268064893","issue_url":"https://api.github.com/repos/confluentinc/kafka-rest-node/issues/14","id":268064893,"user":{"login":"toaderflorin","id":6891040,"avatar_url":"https://avatars.githubusercontent.com/u/6891040?v=3","gravatar_id":"","url":"https://api.github.com/users/toaderflorin","html_url":"https://github.com/toaderflorin","followers_url":"https://api.github.com/users/toaderflorin/followers","following_url":"https://api.github.com/users/toaderflorin/following{/other_user}","gists_url":"https://api.github.com/users/toaderflorin/gists{/gist_id}","starred_url":"https://api.github.com/users/toaderflorin/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/toaderflorin/subscriptions","organizations_url":"https://api.github.com/users/toaderflorin/orgs","repos_url":"https://api.github.com/users/toaderflorin/repos","events_url":"https://api.github.com/users/toaderflorin/events{/privacy}","received_events_url":"https://api.github.com/users/toaderflorin/received_events","type":"User","site_admin":false},"created_at":"2016-12-19T20:08:25Z","updated_at":"2016-12-19T20:08:25Z","body":"Is there any update on this? From what I see, there isn't support for this in the library."}}
{"actor":{"display_login":"toaderflorin"}}