Uploaded image for project: 'Crunch'
  1. Crunch
  2. CRUNCH-653

KafkaSource should provide ConsumerRecord

    Details

    • Type: New Feature
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • 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

        Activity

        There are no comments yet on this issue.

          People

          • Assignee:
            Unassigned
            Reporter:
            bbaugher Bryan Baugher
          • Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

            • Created:
              Updated:

              Development