Mateusz Owczarek created KAFKA-7753:
---------------------------------------
Summary: 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
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)
