[CRUNCH-653] KafkaSource should provide ConsumerRecord - ASF JIRA

XML

Word

Printable

JSON

Details

Type: New Feature
Status: Resolved
Priority: Major
Resolution: Fixed
Affects Version/s: None
Fix Version/s: 1.0.0
Component/s: None
Labels:
None

Description

The existing KafkaSource provides a Pair<BytesWritable, BytesWritable> representing a message's key and value. It would be helpful if the source provided the entire ConsumerRecord so we could have access to the meta information

Attachments

- Sort By Name
- Sort By Date
- Ascending
- Descending

0001-CRUNCH-653-Created-KafkaSource-that-provides-Consume.patch
17/Aug/17 15:37
98 kB
Bryan Baugher

Activity

People

Assignee:: Josh Wills

Reporter:: Bryan Baugher

Votes:: 0 Vote for this issue

Watchers:: 2 Start watching this issue

Dates

Created:: 16/Aug/17 21:16

Updated:: 27/Oct/17 04:07

Resolved:: 27/Oct/17 04:07