Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-5185

Adding the RecordMetadata that is returned by the producer to the commitRecord method for SourceTask

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • None
    • connect
    • None

    Description

      An improvement request I thought would be useful.

      Added the producers record metadata object to the commitRecord method on the SourceTask class so more data is provided from the producer and it allows anyone overriding and hooking into the commitRecord method to receive more information about where the record was procuded to.

      Left the old commitRecord method with just the sourcerecord for backwards compatbility even though this would technically be included in a new version of kafka, it would intoduce a breaking change without it.

      Opened up PR here: https://github.com/apache/kafka/pull/2989

      Attachments

        Issue Links

          relates to

          New Feature - A new feature of the product, which has yet to be developed. KAFKA-7500 MirrorMaker 2.0 (KIP-382)

          • Major - Major loss of function.
          • Resolved
          links to

          Web Link GitHub Pull Request #2989

          Activity

            People

              Unassigned Unassigned
              GeoSmith George Smith
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: