Skip to content

Instantly share code, notes, and snippets.

@luszczynski
Created September 2, 2021 21:51
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save luszczynski/3bc84f055d706784c76e8f13b6fcdbe8 to your computer and use it in GitHub Desktop.
Save luszczynski/3bc84f055d706784c76e8f13b6fcdbe8 to your computer and use it in GitHub Desktop.
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaMirrorMaker2
metadata:
name: my-mm2-cluster1
namespace: mm2
spec:
clusters:
- alias: my-cluster-a
bootstrapServers: 'my-cluster-a-kafka-bootstrap:9092'
- alias: my-cluster-b
bootstrapServers: 'my-cluster-b-kafka-bootstrap:9092'
config:
config.storage.replication.factor: 1
offset.storage.replication.factor: 1
status.storage.replication.factor: 1
connectCluster: my-cluster-b
mirrors:
- checkpointConnector:
config:
checkpoints.topic.replication.factor: 1
emit.checkpoints.interval.seconds: 60
refresh.groups.interval.seconds: 60
sync.group.offsets.enabled: true
sync.group.offsets.interval.seconds: 60
groupsPattern: .*
heartbeatConnector:
config:
heartbeats.topic.replication.factor: 1
sourceCluster: my-cluster-a
sourceConnector:
config:
offset-syncs.topic.replication.factor: 1
refresh.topics.interval.seconds: 60
replication.factor: 1
sync.topic.acls.enabled: 'false'
targetCluster: my-cluster-b
topicsPattern: .*
replicas: 1
version: 2.7.0
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment