GitHub user pengyanhong opened a pull request:
https://github.com/apache/spark/pull/1602
add Kafka stream feature in according to specified starting offset position
to fetch messages
create Kafka input DStream to fetch batch messages from specified starting
position
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/pengyanhong/spark master
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/spark/pull/1602.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1602
----
commit 618f6b766355d37dd91700ae3c48785981cf5bd9
Author: pengyanhong <[email protected]>
Date: 2014-07-24T15:07:30Z
add Kafka stream feature in according to specified starting offset position
to fetch messages
commit a6312058bc3bc6ea0998861f23593f2b2f0450b3
Author: pengyanhong <[email protected]>
Date: 2014-07-24T15:08:42Z
add Kafka stream feature in according to specified starting offset position
to fetch messages
commit 555038fd91ac9f92c0df0519d1407b948aa8737e
Author: pengyanhong <[email protected]>
Date: 2014-07-26T14:58:24Z
refactor code
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
