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

Update KTable.transformValues to new Processor API

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Open
    • Major
    • Resolution: Unresolved
    • None
    • 4.1.0
    • streams

    Description

      The original Processor API was replace by a type-safe version using `Record` instead of K/V pairs. The old PAPI is already mainly deprecated and will be remove to large parts in 4.0 release.

      However, `KTable.transformValues` is still using the old PAPI, and should be updated to use the new `api.FixedKeyProcessor` instead of the old `ValueTransformerWithKey`.

      The method `transformValues` should be deprecated and replaced with `processValues` to `KTable.processValues`.

      At the same time, the old interfaces `ValueTransformerWithKey` and `ValueTransfromerWithKeySupplier` should be deprecated.

      Attachments

        Issue Links

          relates to

          Improvement - An improvement or enhancement to an existing feature or task. KAFKA-17131 Cleanup `ProcessorContext` usage

          • Major - Major loss of function.
          • Patch Available

          Activity

            People

              ableegoldman A. Sophie Blee-Goldman
              mjsax Matthias J. Sax
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated: