[
https://issues.apache.org/jira/browse/KAFKA-17178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-17178:
------------------------------------
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.
KIP-1128:
[https://cwiki.apache.org/confluence/display/KAFKA/KIP-1128%3A+Replace+KTable.transformValues+with+KTable.processValues]
was:
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.
> Update KTable.transformValues to new Processor API
> --------------------------------------------------
>
> Key: KAFKA-17178
> URL: https://issues.apache.org/jira/browse/KAFKA-17178
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Reporter: Matthias J. Sax
> Assignee: Matthias J. Sax
> Priority: Major
> Labels: kip
> Fix For: 4.1.0
>
>
> 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.
> KIP-1128:
> [https://cwiki.apache.org/confluence/display/KAFKA/KIP-1128%3A+Replace+KTable.transformValues+with+KTable.processValues]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
