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
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
