[
https://issues.apache.org/jira/browse/TAJO-1480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15442938#comment-15442938
]
Hudson commented on TAJO-1480:
------------------------------
ABORTED: Integrated in Jenkins build Tajo-master-CODEGEN-build #755 (See
[https://builds.apache.org/job/Tajo-master-CODEGEN-build/755/])
TAJO-1480: Kafka Consumer for kafka strage. (jhkim: rev
d5ffbe645c1fe47e24b3ffe2687cecdfc1ada1b4)
* (add) tajo-storage/tajo-storage-kafka/pom.xml
* (add)
tajo-storage/tajo-storage-kafka/src/main/java/org/apache/tajo/storage/kafka/SimpleConsumerManager.java
* (add)
tajo-storage/tajo-storage-kafka/src/test/java/org/apache/tajo/storage/kafka/server/EmbeddedKafka.java
* (edit) tajo-storage/pom.xml
* (add)
tajo-storage/tajo-storage-kafka/src/test/java/org/apache/tajo/storage/kafka/KafkaTestUtil.java
* (add)
tajo-storage/tajo-storage-kafka/src/test/java/org/apache/tajo/storage/kafka/server/EmbeddedZookeeper.java
* (edit) CHANGES
* (add)
tajo-storage/tajo-storage-kafka/src/test/java/org/apache/tajo/storage/kafka/TestSimpleConsumerManager.java
* (edit) tajo-project/pom.xml
> Kafka Consumer for kafka strage.
> --------------------------------
>
> Key: TAJO-1480
> URL: https://issues.apache.org/jira/browse/TAJO-1480
> Project: Tajo
> Issue Type: Sub-task
> Components: Storage
> Reporter: YeonSu Han
> Assignee: Byunghwa Yun
> Labels: kafka_storage
> Fix For: 0.12.0
>
>
> 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.
> - etc..
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
