17.4. Kafka Connect 업그레이드
다음 절차에서는 호스트 시스템에서 Kafka Connect 클러스터를 업그레이드하는 방법을 설명합니다.
사전 요구 사항
-
kafka사용자로 Red Hat Enterprise Linux에 로그인되어 있습니다. - Kafka Connect가 시작되지 않습니다.
프로세스
AMQ Streams 클러스터의 각 Kafka 브로커와 한 번에 하나씩 다음을 수행합니다.
AMQ Streams 소프트웨어 다운로드 페이지에서 AMQ Streams 아카이브를 다운로드합니다.
참고메시지가 표시되면 Red Hat 계정에 로그인합니다.
명령줄에서 임시 디렉터리를 생성하고
amq-streams-x.y.z-bin.zip파일의 내용을 추출합니다.mkdir /tmp/kafka unzip amq-streams-x.y.z-bin.zip -d /tmp/kafka실행 중인 경우 호스트에서 Kafka 브로커 및 Zoo Cryostat 실행을 중지합니다.
/opt/kafka/bin/kafka-server-stop.sh /opt/kafka/bin/zookeeper-server-stop.sh기존 설치에서
libs및bin디렉토리를 삭제합니다.rm -rf /opt/kafka/libs /opt/kafka/bin임시 디렉토리에서
libs및bin디렉토리를 복사합니다.cp -r /tmp/kafka/kafka_y.y-x.x.x/libs /opt/kafka/ cp -r /tmp/kafka/kafka_y.y-x.x.x/bin /opt/kafka/임시 디렉터리를 삭제합니다.
rm -r /tmp/kafka독립 실행형 또는 분산 모드에서 Kafka 연결을 시작합니다.
독립 실행형 모드에서 시작하려면
connect-standalone.sh스크립트를 실행합니다. Kafka Connect 독립 실행형 구성 파일과 Kafka Connect 커넥터의 구성 파일을 지정합니다.su - kafka /opt/kafka/bin/connect-standalone.sh /opt/kafka/config/connect-standalone.properties connector1.properties [connector2.properties ...]분산 모드에서 시작하려면 모든 Kafka Connect 노드에서
/opt/kafka/config/connect-distributed.properties구성 파일을 사용하여 Kafka Connect 작업자를 시작합니다.su - kafka /opt/kafka/bin/connect-distributed.sh /opt/kafka/config/connect-distributed.properties
Kafka Connect가 실행 중인지 확인합니다.
독립 실행형 모드에서 다음을 수행합니다.
jcmd | grep ConnectStandalone분산 모드에서:
jcmd | grep ConnectDistributed
- Kafka Connect가 데이터를 예상대로 생성하고 사용하는지 확인합니다.