[jira] [Resolved] (KAFKA-7753) ValueTransformerWithKey should not require producing one value every message

["Mateusz Owczarek (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-7753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Mateusz Owczarek resolved KAFKA-7753.
-------------------------------------
    Resolution: Feedback Received

> ValueTransformerWithKey should not require producing one value every message
> ----------------------------------------------------------------------------
>
>                 Key: KAFKA-7753
>                 URL: https://issues.apache.org/jira/browse/KAFKA-7753
>             Project: Kafka
>          Issue Type: Wish
>          Components: streams
>            Reporter: Mateusz Owczarek
>            Priority: Minor
>
> Hi, speaking about: [https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKey.java]
> I have a quite simple case - I want to implement a Transformer which I will use later in my DSL-api-defined topology. Those are my requirements:
> - no repartition topic should be created since I do not change the keys
> - I can't forward messages on every message transformed. I have my internal state store which I'm using to ensure max. 1 message per window is sent.
> Basic transformer gives me possibility to not send messages down the stream (null internal handler), but it forces repartitioning which I think is unnecessary in my case. WDYT?



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)