YeonSu Han created TAJO-1480:
--------------------------------
Summary: 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: YeonSu Han
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.
- fetch(): Fetch data from kafka.
- getReadOffset(): Get offset from specific partition.
- findLeader(): Find leader broker of specific partition.
- etc..
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
