[
https://issues.apache.org/jira/browse/KAFKA-12213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17280034#comment-17280034
]
Piotr Fras edited comment on KAFKA-12213 at 2/5/21, 11:02 PM:
--------------------------------------------------------------
I am going to break down KIP-149 into five streams of work and submit
individual pull request for each of the following interfaces, for both Java and
Scala API:
- ValueTransformer
- ValueMapper
- ValueJoiner
- Initializer (already addressed in [https://github.com/apache/kafka/pull/9908])
- Reducer
Let me know if that works for you.
was (Author: moncalamari):
I am going to break down KIP-149 into five streams of work and submit
individual pull request for each of the following interfaces:
- ValueTransformer
- ValueMapper
- ValueJoiner
- Initializer (already addressed in [https://github.com/apache/kafka/pull/9908])
- Reducer
Let me know if that works for you.
> Kafka Streams aggregation Initializer to accept record key
> ----------------------------------------------------------
>
> Key: KAFKA-12213
> URL: https://issues.apache.org/jira/browse/KAFKA-12213
> Project: Kafka
> Issue Type: New Feature
> Components: streams
> Reporter: Piotr Fras
> Assignee: Piotr Fras
> Priority: Minor
> Labels: needs-kip
>
> Sometimes Kafka record key contains useful information for creating a zero
> object in aggregation Initializer. This feature is to add kafka record key to
> Initializer.
> There were two approaches I considered to implement this feature, one
> respecting backwards compatibility for internal and external APIs and the
> other one which is not. I chose the latter one as it was more strait-forward.
> We may want to validate this approach tho.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
