Kafka
  1. Kafka
  2. KAFKA-625

Improve MessageAndMetadata to expose the partition

    Details

    • Type: Bug Bug
    • Status: Closed
    • Priority: Critical Critical
    • Resolution: Duplicate
    • Affects Version/s: 0.8.0
    • Fix Version/s: 0.8.0
    • Component/s: None
    • Labels:
      None

      Description

      Currently, the high level consumer returns an object of type MessageAndMetadata. This contains the message and the topic to which it belongs. It is useful to know the partition since partition is the granularity that is relevant wrt to everything related to replication and messages live in partitions. This is also useful for applications that use key based partitioning since they would like to associate the message to the partition that it came from.

        Activity

        Neha Narkhede created issue -
        Hide
        Neha Narkhede added a comment -

        Fixed as part of KAFKA-544

        Show
        Neha Narkhede added a comment - Fixed as part of KAFKA-544
        Neha Narkhede made changes -
        Field Original Value New Value
        Status Open [ 1 ] Resolved [ 5 ]
        Fix Version/s 0.8 [ 12317244 ]
        Resolution Duplicate [ 3 ]
        Neha Narkhede made changes -
        Status Resolved [ 5 ] Closed [ 6 ]
        Tony Stevenson made changes -
        Workflow no-reopen-closed, patch-avail [ 12734562 ] Apache Kafka Workflow [ 13052792 ]
        Tony Stevenson made changes -
        Workflow Apache Kafka Workflow [ 13052792 ] no-reopen-closed, patch-avail [ 13055415 ]
        Transition Time In Source Status Execution Times Last Executer Last Execution Date
        Open Open Resolved Resolved
        3h 6m 1 Neha Narkhede 18/Nov/12 22:16
        Resolved Resolved Closed Closed
        4s 1 Neha Narkhede 18/Nov/12 22:17

          People

          • Assignee:
            Unassigned
            Reporter:
            Neha Narkhede
          • Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

            • Created:
              Updated:
              Resolved:

              Development