{"action":"created","issue":{"url":"https://api.github.com/repos/mcollina/ascoltatori/issues/158","repository_url":"https://api.github.com/repos/mcollina/ascoltatori","labels_url":"https://api.github.com/repos/mcollina/ascoltatori/issues/158/labels{/name}","comments_url":"https://api.github.com/repos/mcollina/ascoltatori/issues/158/comments","events_url":"https://api.github.com/repos/mcollina/ascoltatori/issues/158/events","html_url":"https://github.com/mcollina/ascoltatori/issues/158","id":190288397,"number":158,"title":"Kafka ascoltatore is not using HighLevelConsumer","user":{"login":"svarkey","id":17825590,"avatar_url":"https://avatars.githubusercontent.com/u/17825590?v=3","gravatar_id":"","url":"https://api.github.com/users/svarkey","html_url":"https://github.com/svarkey","followers_url":"https://api.github.com/users/svarkey/followers","following_url":"https://api.github.com/users/svarkey/following{/other_user}","gists_url":"https://api.github.com/users/svarkey/gists{/gist_id}","starred_url":"https://api.github.com/users/svarkey/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/svarkey/subscriptions","organizations_url":"https://api.github.com/users/svarkey/orgs","repos_url":"https://api.github.com/users/svarkey/repos","events_url":"https://api.github.com/users/svarkey/events{/privacy}","received_events_url":"https://api.github.com/users/svarkey/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":4,"created_at":"2016-11-18T10:43:10Z","updated_at":"2016-11-18T10:46:33Z","closed_at":null,"body":"I have noticed the Kafka client as part of this integration is using the Simple consumer. As part of our project, we need to use HighLevelConsumer to get the queue functionality from Kafka.\r\n\r\n\r\nTo achieve the above we need to modify the _startConn method in  kafka_ascoltatore.js something like this \r\n````javascript \r\nif (useHighLevelConsumer) {\r\n            that._consumer = new HighLevelConsumer(that._consumerClient, subscriptions, {\r\n                groupId: groupId,\r\n                fromOffset: true, autoCommit: false, encoding: \"buffer\"\r\n            });\r\n        } else {\r\n            that._consumer = new Consumer(that._consumerClient, subscriptions, {\r\n                groupId: groupId,\r\n                fromOffset: true, autoCommit: false, encoding: \"buffer\"\r\n            });\r\n        }\r\n````"},"comment":{"url":"https://api.github.com/repos/mcollina/ascoltatori/issues/comments/261502816","html_url":"https://github.com/mcollina/ascoltatori/issues/158#issuecomment-261502816","issue_url":"https://api.github.com/repos/mcollina/ascoltatori/issues/158","id":261502816,"user":{"login":"mcollina","id":52195,"avatar_url":"https://avatars.githubusercontent.com/u/52195?v=3","gravatar_id":"","url":"https://api.github.com/users/mcollina","html_url":"https://github.com/mcollina","followers_url":"https://api.github.com/users/mcollina/followers","following_url":"https://api.github.com/users/mcollina/following{/other_user}","gists_url":"https://api.github.com/users/mcollina/gists{/gist_id}","starred_url":"https://api.github.com/users/mcollina/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/mcollina/subscriptions","organizations_url":"https://api.github.com/users/mcollina/orgs","repos_url":"https://api.github.com/users/mcollina/repos","events_url":"https://api.github.com/users/mcollina/events{/privacy}","received_events_url":"https://api.github.com/users/mcollina/received_events","type":"User","site_admin":false},"created_at":"2016-11-18T10:46:33Z","updated_at":"2016-11-18T10:46:33Z","body":"Thanks!"}}
{"actor":{"display_login":"mcollina"}}