crunch-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Bryan Baugher (JIRA)" <>
Subject [jira] [Created] (CRUNCH-653) KafkaSource should provide ConsumerRecord
Date Wed, 16 Aug 2017 21:17:00 GMT
Bryan Baugher created CRUNCH-653:

             Summary: KafkaSource should provide ConsumerRecord
                 Key: CRUNCH-653
             Project: Crunch
          Issue Type: New Feature
            Reporter: Bryan Baugher

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

View raw message