`KGroupedStream` is just an "intermediate representation" to get a
better flow in the DSL. It's not a "top level" abstraction like
KStream/KTable.
For `KTable` there is `transformValue()` -- there is no `transform()`
because keying must be preserved -- if you want to change the keying you
need to use `KTable#groupBy()` (data needs to be repartitioned if you
change the key).
HTH.
-Matthias
On 1/12/24 3:09 AM, Igor Maznitsa wrote:
Hello
Is there any way in Kafka Streams API to have processors for KTable and
KGroupedStream like KStream#transform? How to provide a complex
processor for KTable or KGroupedStream which could provide way to not
downstream events for some business logic?
