[
https://issues.apache.org/jira/browse/KAFKA-4218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4218:
-----------------------------------
Description:
While transforming values via {{KStream.transformValues}} and
{{ValueTransformer}}, the key associated with the value may be needed, even if
it is not changed. For instance, it may be used to access stores.
As of now, the key is not available within these methods and interfaces,
leading to the use of {{KStream.transform}} and {{Transformer}}, and the
unnecessary creation of new {{KeyValue}} objects.
KIP-149:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-149%3A+Enabling+key+access+in+ValueTransformer%2C+ValueMapper%2C+and+ValueJoiner
was:
While transforming values via {{KStream.transformValues}} and
{{ValueTransformer}}, the key associated with the value may be needed, even if
it is not changed. For instance, it may be used to access stores.
As of now, the key is not available within these methods and interfaces,
leading to the use of {{KStream.transform}} and {{Transformer}}, and the
unnecessary creation of new {{KeyValue}} objects.
> Enable access to key in ValueTransformer
> ----------------------------------------
>
> Key: KAFKA-4218
> URL: https://issues.apache.org/jira/browse/KAFKA-4218
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Affects Versions: 0.10.0.1
> Reporter: Elias Levy
> Assignee: Jeyhun Karimov
> Labels: api, kip
>
> While transforming values via {{KStream.transformValues}} and
> {{ValueTransformer}}, the key associated with the value may be needed, even
> if it is not changed. For instance, it may be used to access stores.
> As of now, the key is not available within these methods and interfaces,
> leading to the use of {{KStream.transform}} and {{Transformer}}, and the
> unnecessary creation of new {{KeyValue}} objects.
> KIP-149:
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-149%3A+Enabling+key+access+in+ValueTransformer%2C+ValueMapper%2C+and+ValueJoiner
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
