8.8. 레거시 모드에서 MirrorMaker 2.0 사용

프로세스

1. MirrorMaker consumer.properties 및 producer.properties 파일을 편집하여 MirrorMaker 2.0 기능을 끕니다.

   예를 들면 다음과 같습니다.

   replication.policy.class=org.apache.kafka.mirror.LegacyReplicationPolicy 1
   
   refresh.topics.enabled=false 2
   refresh.groups.enabled=false
   emit.checkpoints.enabled=false
   emit.heartbeats.enabled=false
   sync.topic.configs.enabled=false
   sync.topic.acls.enabled=false

   1

   이전 버전의 mirrorMaker를 에뮬레이션합니다.

   2

   내부 체크포인트 및 하트비트 주제를 포함하여 MirrorMaker 2.0 기능이 비활성화됨

2. 이전 버전의 MirrorMaker와 함께 사용한 속성 파일을 사용하여 변경 사항을 저장하고 MirrorMaker를 다시 시작하십시오.

   su - kafka /opt/kafka/bin/kafka-mirror-maker.sh \
   --consumer.config /opt/kafka/config/consumer.properties \
   --producer.config /opt/kafka/config/producer.properties \
   --num.streams=2

   소비자 속성은 소스 클러스터에 대한 구성을 제공하고 생산자 속성은 대상 클러스터 구성을 제공합니다.

   MirrorMaker는 클러스터 간 연결을 설정합니다.

3. 대상 클러스터에서 Zoo Cryostat 및 Kafka를 시작합니다.

   su - kafka
   /opt/kafka/bin/zookeeper-server-start.sh -daemon /opt/kafka/config/zookeeper.properties

   su - kafka
   /opt/kafka/bin/kafka-server-start.sh -daemon /opt/kafka/config/server.properties

4. 대상 클러스터의 경우 주제가 복제되고 있는지 확인합니다.

   /opt/kafka/bin/kafka-topics.sh --bootstrap-server <broker_address> --list