GitHub user combineads opened a pull request:
https://github.com/apache/tajo/pull/1041
TAJO-1480: Kafka Consumer for kafka strage.
Scanner of kafka storage needs to implement a Kafka Consumer for to fetch
data from kafka.
The Kafka Consumer have methods like this,
- getPartitions(): Get partition id list from specific topic.
- poll(): Fetch data from kafka.
- getEarliestOffset(): Get earliest offset from specific partition.
- getLatestOffset(): Get latest offset from specific partition.
- assign(): Assign specific partition to consumer.
- etc..
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/combineads/tajo TAJO-1480
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/tajo/pull/1041.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 #1041
----
commit 13b581fdf84e125c51957ecd8238fdb49947b313
Author: Byunghwa Yun <[email protected]>
Date: 2016-07-27T09:17:20Z
TAJO-1480: Kafka Consumer for kafka strage.
commit 0000ef44cba06cb22ffc99bec376d5d50affae1c
Author: Byunghwa Yun <[email protected]>
Date: 2016-07-27T09:19:59Z
Limit the random number.
commit 67f3e550646c56c487534ddf7cbcba4977a23e9c
Author: Byunghwa Yun <[email protected]>
Date: 2016-07-27T09:22:45Z
Remove unnecessary file.
----
---
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.
---
