18.4. Kafka 브로커 및 Zoo Cryostat 업그레이드

Apache Kafka 소프트웨어 다운로드 페이지 에서는 Streams for Apache Kafka 아카이브 를 다운로드합니다.

명령줄에서 임시 디렉터리를 생성하고 amq-streams-<version>-bin.zip 파일의 내용을 추출합니다.

mkdir /tmp/kafka
unzip amq-streams-<version>-bin.zip -d /tmp/kafka

실행 중인 경우 호스트에서 실행 중인 Zoo Cryostat 및 Kafka 브로커를 중지합니다.

/opt/kafka/bin/zookeeper-server-stop.sh
/opt/kafka/bin/kafka-server-stop.sh
jcmd | grep zookeeper
jcmd | grep kafka

다중 노드 클러스터에서 Kafka를 실행하는 경우 4.3절. “Kafka 브로커의 정상 롤링 재시작 수행” 을 참조하십시오.

기존 설치에서 libs 및 bin 디렉토리를 삭제합니다.

rm -rf /opt/kafka/libs /opt/kafka/bin

임시 디렉토리에서 libs 및 bin 디렉토리를 복사합니다.

cp -r /tmp/kafka/kafka_<version>/libs /opt/kafka/
cp -r /tmp/kafka/kafka_<version>/bin /opt/kafka/

임시 디렉터리를 삭제합니다.

rm -r /tmp/kafka

/opt/kafka/config/server.properties 속성 파일을 편집합니다.

inter.broker.protocol.version 및 log.message.format.version 속성을 현재 버전으로 설정합니다.

예를 들어 Kafka 버전 3.6.0에서 3.7.0으로 업그레이드하는 경우 현재 버전은 3.6입니다.

inter.broker.protocol.version=3.6
log.message.format.version=3.6

업그레이드 중인 Kafka 버전에 대해 올바른 버전을 사용합니다(3.5,3.6 등). 현재 설정에서 inter.broker.protocol.version 을 변경하지 않으면 브로커가 업그레이드 중에 계속 서로 통신할 수 있습니다.

속성이 구성되지 않은 경우 현재 버전으로 추가합니다.

Kafka 3.0.0 이상에서 업그레이드하는 경우 inter.broker.protocol.version 만 설정하면 됩니다.

업데이트된 Zoo Cryostat 및 Kafka 브로커를 다시 시작하십시오.

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

Kafka 브로커 및 Zoo Cryostat는 최신 Kafka 버전에 바이너리를 사용하기 시작합니다.

멀티 노드 클러스터에서 브로커를 다시 시작하는 방법에 대한 자세한 내용은 4.3절. “Kafka 브로커의 정상 롤링 재시작 수행” 을 참조하십시오.

재시작한 Kafka 브로커가 다음과 같은 파티션 복제본에 도달했는지 확인합니다.

kafka-topics.sh 툴을 사용하여 브로커에 포함된 모든 복제본이 동기화되었는지 확인합니다. 지침은 항목 목록 및 설명을 참조하십시오.

다음 단계에서 새 인터브로커 프로토콜 버전을 사용하도록 Kafka 브로커를 업데이트합니다.

한 번에 하나씩 각 브로커를 업데이트합니다.

/opt/kafka/config/server.properties 파일에서 inter.broker.protocol.version 속성을 3.7 로 설정합니다.

inter.broker.protocol.version=3.7

명령줄에서 수정한 Kafka 브로커를 중지합니다.

/opt/kafka/bin/kafka-server-stop.sh

Kafka가 실행 중이 아닌지 확인합니다.

jcmd | grep kafka

수정한 Kafka 브로커를 다시 시작합니다.

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

Kafka가 실행 중인지 확인합니다.

jcmd | grep kafka

Kafka 3.0.0 이전 버전에서 업그레이드하는 경우 /opt/kafka/config/server.properties 파일에서 log.message.format.version 속성을 3.7 로 설정합니다.

log.message.format.version=3.7

명령줄에서 수정한 Kafka 브로커를 중지합니다.

/opt/kafka/bin/kafka-server-stop.sh

Kafka가 실행 중이 아닌지 확인합니다.

jcmd | grep kafka

수정한 Kafka 브로커를 다시 시작합니다.

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

Kafka가 실행 중인지 확인합니다.

jcmd | grep kafka

재시작한 Kafka 브로커가 다음과 같은 파티션 복제본에 도달했는지 확인합니다.

kafka-topics.sh 툴을 사용하여 브로커에 포함된 모든 복제본이 동기화되었는지 확인합니다. 지침은 항목 목록 및 설명을 참조하십시오.