使用Kafka MirrorMaker灾备，如何查询复制进度？
我使用strimzi-0.26.0布署
cluster-source和cluster-target使用kafka版本是2.7.0
mirrormaker版本是2.7.0
通过mirrormaker从cluster-source的topicA复制到cluster-target，如何判断复制进度根据
是根据消费组偏移量查询吗？目前两个集群都没有消费组
复制前
cluster-source集群有1个topic
topicA
cluster-target集群没有topic
复制后
cluster-source集群有两个topic
topicA
mm2-offset-syncs.cluster-target.internal
cluster-target集群有6个topic
mirrormaker2-cluster-offsets
mirrormaker2-cluster-status
mirrormaker2-cluster-configs
heartbeats
cluster-source.checkpoints.internal
cluster-source.topicA
mirrormaker的yaml文件如下
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaMirrorMaker2
metadata:
name: strimzi-kafka-mirror
labels:
app: strimzi-kafka-mirror
spec:
version: 2.7.0
replicas: 1
connectCluster: "cluster-target"
clusters:
- alias: "cluster-source"
bootstrapServers: bootstrap-source.strimzi.kafka.mid:443
tls:
trustedCertificates:
- secretName: strimzi-source-cluster-ca-cert
certificate: ca.crt
- alias: "cluster-target"
bootstrapServers: bootstrap-target.strimzi.kafka.mid:443
tls:
trustedCertificates:
- secretName: strimzi-target-cluster-ca-cert
certificate: ca.crt
mirrors:
- sourceCluster: "cluster-source"
targetCluster: "cluster-target"
sourceConnector:
config:
sync.topic.acls.enabled: "false"
checkpointConnector:
config:
checkpoints.topic.replication.factor: 3
emit.checkpoints.interval.seconds: 60
refresh.groups.interval.seconds: 600
sync.group.offsets.enabled: "true"
sync.group.offsets.interval.seconds: 60
heartbeatConnector:
config:
heartbeats.topic.replication.factor: 3
topicsPattern: "topicA"
groupsPattern: ".*"回答
和开发者交流更多问题细节吧，去 写回答
相关文章
相似问题
相关问答用户
请输入您想邀请的人