[ https://issues.apache.org/jira/browse/KAFKA-16344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17831700#comment-17831700 ]
Janardhana Gopalachar commented on KAFKA-16344: ----------------------------------------------- Hi [~gharris1727] We tried to perform test in out local setup , we observed for the scenario If messages were written in the Source Kafka Cluster and the target Kafka cluster is created after a delay , then the no of messages written to mm2-offsetsyncsinternal is doubled. Is this the expected behavior? > Internal topic mm2-offset-syncs<clustername>internal created with single > partition is putting more load on the broker > --------------------------------------------------------------------------------------------------------------------- > > Key: KAFKA-16344 > URL: https://issues.apache.org/jira/browse/KAFKA-16344 > Project: Kafka > Issue Type: Bug > Components: connect > Affects Versions: 3.5.1 > Reporter: Janardhana Gopalachar > Priority: Major > > We are using Kafka 3.5.1 version, we see that the internal topic created by > mirrormaker > mm2-offset-syncs<clustername>internal is created with single partition due to > which the CPU load on the broker which will be leader for this partition is > increased compared to other brokers. Can multiple partitions be created for > the topic so that the CPU load would get distributed > > Topic: mm2-offset-syncscluster-ainternal TopicId: XRvTDbogT8ytNhqX2YTyrA > PartitionCount: 1ReplicationFactor: 3 Configs: > min.insync.replicas=2,cleanup.policy=compact,message.format.version=3.0-IV1 > Topic: mm2-offset-syncscluster-ainternal Partition: 0 Leader: 2 > Replicas: 2,1,0 Isr: 2,1,0 -- This message was sent by Atlassian Jira (v8.20.10#820010)