10.9.4. MirrorMaker 2 커넥터 생산자 및 소비자 구성


MirrorMaker 2 커넥터는 내부 생산자와 소비자를 사용합니다. 필요한 경우 이러한 생산자 및 소비자를 구성하여 기본 설정을 덮어쓸 수 있습니다.

예를 들어 많은 양의 메시지를 더 잘 수용하도록 대상 Kafka 클러스터에 주제를 보내는 소스 생산자의 batch.size 를 늘릴 수 있습니다.

중요

생산자 및 소비자 구성 옵션은 MirrorMaker 2 구현에 따라 다르며 변경될 수 있습니다.

다음 표에서는 각 커넥터의 생산자 및 소비자와 구성을 추가할 수 있는 위치를 설명합니다.

표 10.3. 소스 커넥터 생산자 및 소비자
유형설명설정

생산자

대상 Kafka 클러스터로 주제 메시지를 보냅니다. 대량의 데이터를 처리할 때 이 생산자의 구성을 조정하는 것이 좋습니다.

mirrors.sourceConnector.config: producer.override.*

생산자

복제된 주제 파티션에 대한 소스 및 대상 오프셋을 매핑하는 offset-syncs 항목에 씁니다.

mirrors.sourceConnector.config: producer.*

소비자

소스 Kafka 클러스터에서 주제 메시지를 검색합니다.

mirrors.sourceConnector.config: consumer.*

표 10.4. Checkpoint 커넥터 생산자 및 소비자
유형설명설정

생산자

소비자 오프셋 체크포인트를 내보냅니다.

mirrors.checkpointConnector.config: producer.override.*

소비자

offset-syncs 주제를 로드합니다.

mirrors.checkpointConnector.config: consumer.*

참고

target Kafka 클러스터를 offset-syncs 주제의 위치로 사용하도록 offset-syncs.topic.location 을 설정할 수 있습니다.

표 10.5. heartbeat 커넥터 생산자
유형설명설정

생산자

하트비트를 내보냅니다.

mirrors.heartbeatConnector.config: producer.override.*

다음 예제에서는 생산자와 소비자를 구성하는 방법을 보여줍니다.

커넥터 생산자 및 소비자를 위한 구성 예

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaMirrorMaker2
metadata:
  name: my-mirror-maker2
spec:
  version: 4.0.0
  # ...
  mirrors:
  - sourceCluster: "my-cluster-source"
    targetCluster: "my-cluster-target"
    sourceConnector:
      tasksMax: 5
      config:
        producer.override.batch.size: 327680
        producer.override.linger.ms: 100
        producer.request.timeout.ms: 30000
        consumer.fetch.max.bytes: 52428800
        # ...
    checkpointConnector:
      config:
        producer.override.request.timeout.ms: 30000
        consumer.max.poll.interval.ms: 300000
        # ...
    heartbeatConnector:
      config:
        producer.override.request.timeout.ms: 30000
        # ...

Red Hat logoGithubRedditYoutubeTwitter

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 소개

Red Hat은 기업이 핵심 데이터 센터에서 네트워크 에지에 이르기까지 플랫폼과 환경 전반에서 더 쉽게 작업할 수 있도록 강화된 솔루션을 제공합니다.

보다 포괄적 수용을 위한 오픈 소스 용어 교체

Red Hat은 코드, 문서, 웹 속성에서 문제가 있는 언어를 교체하기 위해 최선을 다하고 있습니다. 자세한 내용은 다음을 참조하세요.Red Hat 블로그.

Red Hat 문서 정보

Legal Notice

Theme

© 2026 Red Hat
맨 위로 이동