Replicare Geo-Distribuită cu MirrorMaker 2 (MM2) în Apache Kafka în Apache Kafka

Ghid complet pentru Apache Kafka MirrorMaker 2: sincronizarea clusterelor multi-regiune, disaster recovery activ-pasiv și replicarea bidirecțională activ-activ fără bucle infinite.

Sintaxă
bin/connect-mirror-maker.sh config/mm2.properties

Pentru recuperare în caz de dezastru (Disaster Recovery) și migrare fără întreruperi către cloud, MirrorMaker 2 (MM2) sincronizează datele, topicurile și offset-urile consumatorilor între clustere Kafka aflate în centre de date diferite.

Exemplu de configurare MM2 (Active → Standby)
# Definirea alias-urilor clusterelor:
clusters = bucuresti, frankfurt

bucuresti.bootstrap.servers = kf-buc.internal:9092
frankfurt.bootstrap.servers = kf-fra.internal:9092

# Direcția fluxului de replicare (București către Frankfurt):
bucuresti->frankfurt.enabled = true
bucuresti->frankfurt.topics = .* # replică toate topicurile
bucuresti->frankfurt.sync.group.offsets.enabled = true # sincronizează offset-urile
bucuresti->frankfurt.sync.topic.acls.enabled = true

# Rulare din linia de comandă:
# bin/connect-mirror-maker.sh config/mm2.properties
Comunitate & Schimb de cunoștințe

Întrebări & Exemple de Cod: Replicare Geo-Distribuită cu MirrorMaker 2 (MM2) în Apache Kafka

Ai o nelămurire despre utilizarea comenzii Replicare Geo-Distribuită cu MirrorMaker 2 (MM2) în Apache Kafka sau ai descoperit un truc / fragment de cod util? Distribuie-l cu ceilalți programatori!

💬

Fii primul care pune o întrebare sau distribuie un fragment de cod / prompt!

Nu au fost adăugate încă întrebări sau exemple de cod pentru această pagină. Dacă ai întâlnit o problemă sau ai un snippet util, adaugă-l mai jos pentru a-i ajuta pe ceilalți.

Comunitate Adaugă o întrebare sau distribuie un cod

Moderare & Siguranță:

Pentru a menține calitatea și securitatea informațiilor, fiecare întrebare sau fragment de cod/prompt este analizat (manual sau prin moderare asistată de AI) înainte de publicare.