Can I tell mirrormaker2 to start (re)consuming from a specific offset?

2024-09-12 Thread James Cheng
Hi everyone, I am using Mirrormaker 2. From what I understand, mirrormaker2 does not store its offsets in the source cluster's __consumer_offsets topic. Rather, it stores its offsets in the destination cluster in the value defined by offset.storage.topic In the __consumer_offsets world, I coul

Re: [DISCUSS] Mirroring the Repartition Topic: MirrorMaker2 and Streams interaction

2024-09-12 Thread Greg Harris
Hey everyone, Bumping this topic to see if anyone has experience migrating Streams jobs between clusters with Mirror Maker, and how you handled repartition topics. Thanks! Greg On Mon, Aug 12, 2024 at 8:55 AM Greg Harris wrote: > Hi all, > > We were recently working to set up a MirrorMaker2 fl

Fwd: compression issue on broker side

2024-09-12 Thread Ajit Kharpude
Hello Kafka Team, i am using a three node kafka broker cluster but recently compression issues occur on brocker side. Please provide guillines. broker property: process.roles=broker,controller node.id=0 controller.quorum.voters=0...@kafka-0-0.kafka.prod.svc.cluster.local :9093,1...@kafka-