[ https://issues.apache.org/jira/browse/CRUNCH-653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Bryan Baugher updated CRUNCH-653: --------------------------------- Attachment: 0001-CRUNCH-653-Created-KafkaSource-that-provides-Consume.patch > KafkaSource should provide ConsumerRecord > ----------------------------------------- > > Key: CRUNCH-653 > URL: https://issues.apache.org/jira/browse/CRUNCH-653 > Project: Crunch > Issue Type: New Feature > Reporter: Bryan Baugher > Attachments: > 0001-CRUNCH-653-Created-KafkaSource-that-provides-Consume.patch > > > 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 -- This message was sent by Atlassian JIRA (v6.4.14#64029)