Red Hat Summit15.3. MirrorMaker 및 Kafka Connect에 대한 추적 설정
이 섹션에서는 분산 추적을 위해 MirrorMaker, MirrorMaker 2.0 및 Kafka Connect를 구성하는 방법을 설명합니다.
각 구성 요소에 대해 Jaeger 추적기를 활성화해야 합니다.
15.3.1. MirrorMaker의 추적 활성화
Interceptor 속성을 소비자 및 생산자 구성 매개변수로 전달하여 MirrorMaker에 대한 분산 추적을 활성화합니다.
메시지는 소스 클러스터에서 대상 클러스터로 추적됩니다. 추적 데이터는 MirrorMaker 구성 요소를 입력하고 나가는 메시지를 기록합니다.
프로세스
- Jaeger 추적기를 구성하고 활성화합니다.
/opt/kafka/config/consumer.properties파일을 편집합니다.다음 Interceptor 속성을 추가합니다.
consumer.interceptor.classes=io.opentracing.contrib.kafka.TracingConsumerInterceptor
/opt/kafka/config/producer.properties파일을 편집합니다.다음 Interceptor 속성을 추가합니다.
producer.interceptor.classes=io.opentracing.contrib.kafka.TracingProducerInterceptor
소비자 및 생산자 구성 파일을 매개변수로 사용하여 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
15.3.2. MirrorMaker 2.0의 추적 활성화
MirrorMaker 2.0 속성 파일에서 Interceptor 속성을 정의하여 MirrorMaker 2.0에 대한 분산 추적을 활성화합니다.
Kafka 클러스터 간에 메시지가 추적됩니다. 추적 데이터는 MirrorMaker 2.0 구성 요소를 입력하고 나가는 메시지를 기록합니다.
프로세스
- Jaeger 추적기를 구성하고 활성화합니다.
MirrorMaker 2.0 구성 속성 파일
./config/connect-mirror-maker.properties를 편집하고 다음 속성을 추가합니다.header.converter=org.apache.kafka.connect.converters.ByteArrayConverter 1 consumer.interceptor.classes=io.opentracing.contrib.kafka.TracingConsumerInterceptor 2 producer.interceptor.classes=io.opentracing.contrib.kafka.TracingProducerInterceptor
- MirrorMaker 2.0을 사용하여 Kafka 클러스터 간 데이터 동기화의 지침을 사용하여 MirrorMaker 2.0 을 시작합니다.
15.3.3. Kafka Connect에 대한 추적 활성화
구성 속성을 사용하여 Kafka Connect에 대해 분산 추적을 활성화합니다.
Kafka Connect 자체에서 생성하고 사용하는 메시지만 추적됩니다. Kafka Connect와 외부 시스템 간에 전송된 메시지를 추적하려면 해당 시스템의 커넥터에서 추적을 구성해야 합니다.
프로세스
- Jaeger 추적기를 구성하고 활성화합니다.
관련 Kafka Connect 구성 파일을 편집합니다.
-
독립 실행형 모드에서 Kafka Connect를 실행하는 경우
/opt/kafka/config/connect-standalone.properties파일을 편집합니다. -
분산 모드에서 Kafka Connect를 실행하는 경우
/opt/kafka/config/connect-distributed.properties파일을 편집합니다.
-
독립 실행형 모드에서 Kafka Connect를 실행하는 경우
구성 파일에 다음 속성을 추가합니다.
producer.interceptor.classes=io.opentracing.contrib.kafka.TracingProducerInterceptor consumer.interceptor.classes=io.opentracing.contrib.kafka.TracingConsumerInterceptor
- 구성 파일을 저장합니다.
- 추적 환경 변수를 설정한 다음 독립 실행형 또는 분산 모드에서 Kafka Connect를 실행합니다.
Kafka Connect의 내부 소비자 및 생산자의 인터셉터가 활성화됩니다.
