10.9.4. MirrorMaker 2 커넥터 생산자 및 소비자 구성
MirrorMaker 2 커넥터는 내부 생산자와 소비자를 사용합니다. 필요한 경우 이러한 생산자 및 소비자를 구성하여 기본 설정을 덮어쓸 수 있습니다.
예를 들어 많은 양의 메시지를 더 잘 수용하도록 대상 Kafka 클러스터에 주제를 보내는 소스 생산자의 batch.size 를 늘릴 수 있습니다.
생산자 및 소비자 구성 옵션은 MirrorMaker 2 구현에 따라 다르며 변경될 수 있습니다.
다음 표에서는 각 커넥터의 생산자 및 소비자와 구성을 추가할 수 있는 위치를 설명합니다.
| 유형 | 설명 | 설정 |
|---|---|---|
| 생산자 | 대상 Kafka 클러스터로 주제 메시지를 보냅니다. 대량의 데이터를 처리할 때 이 생산자의 구성을 조정하는 것이 좋습니다. |
|
| 생산자 |
복제된 주제 파티션에 대한 소스 및 대상 오프셋을 매핑하는 |
|
| 소비자 | 소스 Kafka 클러스터에서 주제 메시지를 검색합니다. |
|
| 유형 | 설명 | 설정 |
|---|---|---|
| 생산자 | 소비자 오프셋 체크포인트를 내보냅니다. |
|
| 소비자 |
|
|
target Kafka 클러스터를 offset-syncs 주제의 위치로 사용하도록 offset-syncs.topic.location 을 설정할 수 있습니다.
| 유형 | 설명 | 설정 |
|---|---|---|
| 생산자 | 하트비트를 내보냅니다. |
|
다음 예제에서는 생산자와 소비자를 구성하는 방법을 보여줍니다.
커넥터 생산자 및 소비자를 위한 구성 예
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
# ...