{"action":"created","issue":{"url":"https://api.github.com/repos/emqtt/emqttd/issues/173","labels_url":"https://api.github.com/repos/emqtt/emqttd/issues/173/labels{/name}","comments_url":"https://api.github.com/repos/emqtt/emqttd/issues/173/comments","events_url":"https://api.github.com/repos/emqtt/emqttd/issues/173/events","html_url":"https://github.com/emqtt/emqttd/issues/173","id":87784372,"number":173,"title":"Integration with Kafka.","user":{"login":"dvorobiov","id":906642,"avatar_url":"https://avatars.githubusercontent.com/u/906642?v=3","gravatar_id":"","url":"https://api.github.com/users/dvorobiov","html_url":"https://github.com/dvorobiov","followers_url":"https://api.github.com/users/dvorobiov/followers","following_url":"https://api.github.com/users/dvorobiov/following{/other_user}","gists_url":"https://api.github.com/users/dvorobiov/gists{/gist_id}","starred_url":"https://api.github.com/users/dvorobiov/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/dvorobiov/subscriptions","organizations_url":"https://api.github.com/users/dvorobiov/orgs","repos_url":"https://api.github.com/users/dvorobiov/repos","events_url":"https://api.github.com/users/dvorobiov/events{/privacy}","received_events_url":"https://api.github.com/users/dvorobiov/received_events","type":"User","site_admin":false},"labels":[{"url":"https://api.github.com/repos/emqtt/emqttd/labels/enhancement","name":"enhancement","color":"84b6eb"}],"state":"open","locked":false,"assignee":{"login":"huangdan","id":970300,"avatar_url":"https://avatars.githubusercontent.com/u/970300?v=3","gravatar_id":"","url":"https://api.github.com/users/huangdan","html_url":"https://github.com/huangdan","followers_url":"https://api.github.com/users/huangdan/followers","following_url":"https://api.github.com/users/huangdan/following{/other_user}","gists_url":"https://api.github.com/users/huangdan/gists{/gist_id}","starred_url":"https://api.github.com/users/huangdan/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/huangdan/subscriptions","organizations_url":"https://api.github.com/users/huangdan/orgs","repos_url":"https://api.github.com/users/huangdan/repos","events_url":"https://api.github.com/users/huangdan/events{/privacy}","received_events_url":"https://api.github.com/users/huangdan/received_events","type":"User","site_admin":false},"milestone":{"url":"https://api.github.com/repos/emqtt/emqttd/milestones/25","html_url":"https://github.com/emqtt/emqttd/milestones/0.10.0","labels_url":"https://api.github.com/repos/emqtt/emqttd/milestones/25/labels","id":1074168,"number":25,"title":"0.10.0","description":"","creator":{"login":"erylee","id":11869,"avatar_url":"https://avatars.githubusercontent.com/u/11869?v=3","gravatar_id":"","url":"https://api.github.com/users/erylee","html_url":"https://github.com/erylee","followers_url":"https://api.github.com/users/erylee/followers","following_url":"https://api.github.com/users/erylee/following{/other_user}","gists_url":"https://api.github.com/users/erylee/gists{/gist_id}","starred_url":"https://api.github.com/users/erylee/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/erylee/subscriptions","organizations_url":"https://api.github.com/users/erylee/orgs","repos_url":"https://api.github.com/users/erylee/repos","events_url":"https://api.github.com/users/erylee/events{/privacy}","received_events_url":"https://api.github.com/users/erylee/received_events","type":"User","site_admin":false},"open_issues":10,"closed_issues":0,"state":"open","created_at":"2015-04-19T20:42:49Z","updated_at":"2015-07-14T09:49:21Z","due_on":"2015-08-28T16:00:00Z","closed_at":null},"comments":4,"created_at":"2015-06-12T16:43:00Z","updated_at":"2015-07-22T05:33:03Z","closed_at":null,"body":"I would like to suggest the functionality when mqtt get messages you can re-publish them to Kafka. And if you publish data to some topic in Kafka, the emqtt re-publish them within the broker."},"comment":{"url":"https://api.github.com/repos/emqtt/emqttd/issues/comments/123569313","html_url":"https://github.com/emqtt/emqttd/issues/173#issuecomment-123569313","issue_url":"https://api.github.com/repos/emqtt/emqttd/issues/173","id":123569313,"user":{"login":"lsxredrain","id":5266023,"avatar_url":"https://avatars.githubusercontent.com/u/5266023?v=3","gravatar_id":"","url":"https://api.github.com/users/lsxredrain","html_url":"https://github.com/lsxredrain","followers_url":"https://api.github.com/users/lsxredrain/followers","following_url":"https://api.github.com/users/lsxredrain/following{/other_user}","gists_url":"https://api.github.com/users/lsxredrain/gists{/gist_id}","starred_url":"https://api.github.com/users/lsxredrain/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/lsxredrain/subscriptions","organizations_url":"https://api.github.com/users/lsxredrain/orgs","repos_url":"https://api.github.com/users/lsxredrain/repos","events_url":"https://api.github.com/users/lsxredrain/events{/privacy}","received_events_url":"https://api.github.com/users/lsxredrain/received_events","type":"User","site_admin":false},"created_at":"2015-07-22T05:33:03Z","updated_at":"2015-07-22T05:33:03Z","body":"git clone git://github.com/wooga/eredis.git plugins\r\nthen we can use eredis in any files，for example as follow\r\n{ok, C} = eredis:start_link(\"127.0.0.1\", 6379, 0),\r\n{ok, <<\"OK\">>} = eredis:q(C, [\"SET\", \"foo\", \"bar\"]),\r\n{ok, SetResult} = eredis:q(C, [\"SET\", \"foo\", \"bar\"]),\r\nio:format(\"~n~p~n\", [SetResult]),\r\n{ok, GetReuslt} = eredis:q(C, [\"GET\", \"foo\"]),\r\nio:format(\"~n~p~n\", [GetReuslt]),"}}