Details
-
Sub-task
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
Description
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..
Attachments
Issue Links
- is depended upon by
-
TAJO-1487 Kafka Scanner for Kafka Storage
- Resolved
- links to