[
https://issues.apache.org/jira/browse/KAFKA-15505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Srinivas Boga updated KAFKA-15505:
----------------------------------
Description:
I am running mirrormaker2 in distributed mode with 3 nodes and 10 tasks each ,
kafka version: 3.5.1
On the source cluster , i see the consumer group has subscriptions of topic-A
and topic-B, but on the target cluster i am seeing only the subscription of
topic-A
restarting did not help, Also the the consumed offsets of the topic-A are
different on the target cluster, i see the lag of zero for all partitions on
source cluster, but the lag keeps building up on the target cluster
{code:java}
sync.group.offsets.enabled = true
sync.group.offsets.interval.seconds = 1{code}
Any help on this would be appreciated
Thanks,
-srini
was:
I am running mirrormaker2 in distributed mode with 3 nodes and 10 tasks each ,
kafka version: 3.5.1
On the source cluster , i see the consumer group has subscriptions of topic-A
and topic-B, but on the target cluster i am seeing only the subscription of
topic-A
restarting did not help, Also the the consumed offsets of the topic-A are
different on the target cluster, i see the lag of zero for all partitions on
source cluster, but the lag keeps building up on the target cluster
Any help on this would be appreciated
Thanks,
-srini
> MM2 consumer group subscription different on target cluster
> -----------------------------------------------------------
>
> Key: KAFKA-15505
> URL: https://issues.apache.org/jira/browse/KAFKA-15505
> Project: Kafka
> Issue Type: Bug
> Components: mirrormaker
> Reporter: Srinivas Boga
> Priority: Major
>
> I am running mirrormaker2 in distributed mode with 3 nodes and 10 tasks each
> , kafka version: 3.5.1
> On the source cluster , i see the consumer group has subscriptions of topic-A
> and topic-B, but on the target cluster i am seeing only the subscription of
> topic-A
> restarting did not help, Also the the consumed offsets of the topic-A are
> different on the target cluster, i see the lag of zero for all partitions on
> source cluster, but the lag keeps building up on the target cluster
> {code:java}
> sync.group.offsets.enabled = true
> sync.group.offsets.interval.seconds = 1{code}
>
> Any help on this would be appreciated
>
> Thanks,
> -srini
>
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
