{"action":"created","issue":{"url":"https://api.github.com/repos/intel-hadoop/gearpump/issues/834","labels_url":"https://api.github.com/repos/intel-hadoop/gearpump/issues/834/labels{/name}","comments_url":"https://api.github.com/repos/intel-hadoop/gearpump/issues/834/comments","events_url":"https://api.github.com/repos/intel-hadoop/gearpump/issues/834/events","html_url":"https://github.com/intel-hadoop/gearpump/pull/834","id":69194304,"number":834,"title":"Fixes #719 add Kafka Source and HBase Sink for dsl","user":{"login":"kkasravi","id":146453,"avatar_url":"https://avatars.githubusercontent.com/u/146453?v=3","gravatar_id":"","url":"https://api.github.com/users/kkasravi","html_url":"https://github.com/kkasravi","followers_url":"https://api.github.com/users/kkasravi/followers","following_url":"https://api.github.com/users/kkasravi/following{/other_user}","gists_url":"https://api.github.com/users/kkasravi/gists{/gist_id}","starred_url":"https://api.github.com/users/kkasravi/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/kkasravi/subscriptions","organizations_url":"https://api.github.com/users/kkasravi/orgs","repos_url":"https://api.github.com/users/kkasravi/repos","events_url":"https://api.github.com/users/kkasravi/events{/privacy}","received_events_url":"https://api.github.com/users/kkasravi/received_events","type":"User","site_admin":false},"labels":[{"url":"https://api.github.com/repos/intel-hadoop/gearpump/labels/in%20progress","name":"in progress","color":"ededed"}],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":14,"created_at":"2015-04-17T18:40:47Z","updated_at":"2015-04-20T15:24:24Z","closed_at":null,"pull_request":{"url":"https://api.github.com/repos/intel-hadoop/gearpump/pulls/834","html_url":"https://github.com/intel-hadoop/gearpump/pull/834","diff_url":"https://github.com/intel-hadoop/gearpump/pull/834.diff","patch_url":"https://github.com/intel-hadoop/gearpump/pull/834.patch"},"body":"Modeled after CanBuildFrom where an implicit graph is made available to each Stream[T]'s methods.  The implicit graph should be injectable (noted in TODO in StreamApp object)\n\n<!-- Reviewable:start -->\n[<img src=\"https://reviewable.io/review_button.png\" height=40 alt=\"Review on Reviewable\"/>](https://reviewable.io/reviews/intel-hadoop/gearpump/834)\n<!-- Reviewable:end -->\n"},"comment":{"url":"https://api.github.com/repos/intel-hadoop/gearpump/issues/comments/94482922","html_url":"https://github.com/intel-hadoop/gearpump/pull/834#issuecomment-94482922","issue_url":"https://api.github.com/repos/intel-hadoop/gearpump/issues/834","id":94482922,"user":{"login":"clockfly","id":2595532,"avatar_url":"https://avatars.githubusercontent.com/u/2595532?v=3","gravatar_id":"","url":"https://api.github.com/users/clockfly","html_url":"https://github.com/clockfly","followers_url":"https://api.github.com/users/clockfly/followers","following_url":"https://api.github.com/users/clockfly/following{/other_user}","gists_url":"https://api.github.com/users/clockfly/gists{/gist_id}","starred_url":"https://api.github.com/users/clockfly/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/clockfly/subscriptions","organizations_url":"https://api.github.com/users/clockfly/orgs","repos_url":"https://api.github.com/users/clockfly/repos","events_url":"https://api.github.com/users/clockfly/events{/privacy}","received_events_url":"https://api.github.com/users/clockfly/received_events","type":"User","site_admin":false},"created_at":"2015-04-20T15:24:24Z","updated_at":"2015-04-20T15:24:24Z","body":"@kkasravi \r\n\r\nIt may be challenging to support any ReplayableSource in a generic way.\r\nHow about adding a OP specifially for kafka.\r\n\r\nSomething like:\r\n```\r\nStream.fromKafka[T](kafkaConfig， other config) {\r\n}\r\n```\r\n\r\nWhen we get more confidence about supporting generic Replayable source, then we can revisit this.\r\n"}}