Re: [Kafka Streams], Processor API for KTable and KGroupedStream

[Igor Maznitsa]

Thanks a lot for explanation but could you provide a bit more details 
about KGroupedStream? It is just interface and not extends KStream so 
how I can add processor in the case below?

/
  KStream someStream = /
/  someStream /
/     .groupByKey()
/ */how to add processor for resulted grouped stream here ???/*

On 2024-Jan-13 01:22, Matthias J. Sax wrote:
`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 11:47 AM, Igor Maznitsa wrote:

Hello

Is there any way in Kafka Streams API to define processors for KTable 
and KGroupedStream like KStream#transform? How to provide a custom 
processor for KTable or KGroupedStream which could for instance 
provide way to not downstream selected events?

Mirror Maker 2 | 2.7.1 | Some partitions are not synched since target cluster patching

[Akshaya Rawat]

Hi Team,
We are using MM2 v2.7.1 to replicate Kafka.
We noticed that the topic replication was working fine. However due to
security patching the target cluster was restarted and since then some of
the partitions are not synched.
Can you help us identify the issue ?

Regards,
Akshaya