您的位置:首页 > 科技 > 能源 > 免费二级域名分发系统_网络推广技术培训_营销推广方案包括哪些内容_上海关键词排名手机优化软件

免费二级域名分发系统_网络推广技术培训_营销推广方案包括哪些内容_上海关键词排名手机优化软件

2024/12/25 21:07:44 来源:https://blog.csdn.net/qq_36481693/article/details/144691366  浏览:    关键词:免费二级域名分发系统_网络推广技术培训_营销推广方案包括哪些内容_上海关键词排名手机优化软件
免费二级域名分发系统_网络推广技术培训_营销推广方案包括哪些内容_上海关键词排名手机优化软件

目的

使用mm2进行kafka集群迁移的时候默认配会给target 集群的topic加一个前缀。要想去掉前缀需要使用如下配置添加一条副本策略(replication.policy.class: “org.apache.kafka.connect.mirror.IdentityReplicationPolicy”)。

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaMirrorMaker2
metadata:name: my-mirror-maker-2
spec:version: 3.9.0replicas: 1connectCluster: "cluster-b" # Must be the target custerclusters:- alias: "cluster-a" # Source clusterbootstrapServers: cluster-a-kafka-bootstrap:9092- alias: "cluster-b" # Target clusterbootstrapServers: cluster-b-kafka-bootstrap:9092config:# -1 means it will use the default replication factor configured in the brokerconfig.storage.replication.factor: -1offset.storage.replication.factor: -1status.storage.replication.factor: -1mirrors:- sourceCluster: "cluster-a"targetCluster: "cluster-b"sourceConnector:tasksMax: 1config:# -1 means it will use the default replication factor configured in the brokerreplication.factor: -1offset-syncs.topic.replication.factor: -1sync.topic.acls.enabled: "false"replication.policy.class: "org.apache.kafka.connect.mirror.IdentityReplicationPolicy"refresh.topics.interval.seconds: 600checkpointConnector:tasksMax: 1config:# -1 means it will use the default replication factor configured in the brokercheckpoints.topic.replication.factor: -1replication.policy.class: "org.apache.kafka.connect.mirror.IdentityReplicationPolicy"sync.group.offsets.enabled: "false"refresh.groups.interval.seconds: 600topicsPattern: ".*"groupsPattern: ".*"

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com