KPL 0.x에서 KPL 1.x로 마이그레이션 - Amazon Kinesis Data Streams

기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

KPL 0.x에서 KPL 1.x로 마이그레이션

이 주제에서는 소비자를 KPL 0.x에서 KPL 1.x로 마이그레이션하는 단계별 지침을 제공합니다. KPL 1.x는 이전 버전과의 인터페이스 호환성을 유지하면서 AWS SDK for Java 2.x에 대한 지원을 도입합니다. KPL 1.x로 마이그레이션하기 위해 코어 데이터 처리 로직을 업데이트하지 않아도 됩니다.

  1. 다음 사전 조건을 충족하는지 확인합니다.

    • Java Development Kit(JDK) 8 이상

    • AWS SDK for Java 2.x

    • 종속성 관리를 위한 Maven 또는 Gradle

  2. 종속성 추가

    Maven을 사용하는 경우 pom.xml 파일에 다음 종속성을 추가합니다. groupId를 com.amazonaws에서 software.amazon.kinesis로, 버전 1.x.x를 최신 KPL 버전으로 업데이트했는지 확인합니다.

    <dependency>
    <groupId>software.amazon.kinesis</groupId>
    <artifactId>amazon-kinesis-producer</artifactId>
    <version>1.x.x</version> <!-- Use the latest version -->
</dependency>

    Gradle을 사용하는 경우 build.gradle 파일에 다음을 추가합니다. 1.x.x를 최신 KPL 버전으로 바꿔야 합니다.

    implementation 'software.amazon.kinesis:amazon-kinesis-producer:1.x.x'

    Maven Central Repository에서 최신 버전의 KPL을 확인할 수 있습니다.

  3. KPL에 대한 가져오기 문 업데이트

    KPL 1.x는 AWS SDK for Java 2.x를 사용하며 com.amazonaws.services.kinesis로 시작하는 이전 KPL의 패키지 이름과 비교하여 software.amazon.kinesis로 시작하는 업데이트된 패키지 이름을 사용합니다

    com.amazonaws.services.kinesis에 대한 가져오기를 software.amazon.kinesis로 바꿉니다. 다음 표에는 교체해야 하는 가져오기가 나열되어 있습니다.

    가져오기 교체 항목
    다음과 같이 바꿉니다. 변경 후:

    com.amazonaws.services.kinesis.producer.Attempt; 가져오기

    software.amazon.kinesis.producer.Attempt; 가져오기

    com.amazonaws.services.kinesis.producer.BinaryToHexConverter; 가져오기

    software.amazon.kinesis.producer.BinaryToHexConverter; 가져오기

    com.amazonaws.services.kinesis.producer.CertificateExtractor; 가져오기

    software.amazon.kinesis.producer.CertificateExtractor; 가져오기

    com.amazonaws.services.kinesis.producer.Daemon; 가져오기

    software.amazon.kinesis.producer.Daemon; 가져오기

    com.amazonaws.services.kinesis.producer.DaemonException; 가져오기

    software.amazon.kinesis.producer.DaemonException; 가져오기

    com.amazonaws.services.kinesis.producer.FileAgeManager 가져오기;

    software.amazon.kinesis.producer.FileAgeManager 가져오기;

    com.amazonaws.services.kinesis.producer.FutureTimedOutException 가져오기;

    software.amazon.kinesis.producer.FutureTimedOutException 가져오기;

    com.amazonaws.services.kinesis.producer.GlueSchemaRegistrySerializerInstance 가져오기;

    software.amazon.kinesis.producer.GlueSchemaRegistrySerializerInstance 가져오기;

    com.amazonaws.services.kinesis.producer.HashedFileCopier 가져오기;

    software.amazon.kinesis.producer.HashedFileCopier 가져오기;

    com.amazonaws.services.kinesis.producer.IKinesisProducer 가져오기;

    software.amazon.kinesis.producer.IKinesisProducer 가져오기;

    com.amazonaws.services.kinesis.producer.IrrecoverableError 가져오기;

    software.amazon.kinesis.producer.IrrecoverableError 가져오기;

    com.amazonaws.services.kinesis.producer.KinesisProducer 가져오기;

    software.amazon.kinesis.producer.KinesisProducer 가져오기;

    com.amazonaws.services.kinesis.producer.KinesisProducerConfiguration 가져오기;

    software.amazon.kinesis.producer.KinesisProducerConfiguration 가져오기;

    com.amazonaws.services.kinesis.producer.LogInputStreamReader 가져오기;

    software.amazon.kinesis.producer.LogInputStreamReader 가져오기;

    com.amazonaws.services.kinesis.producer.Metric 가져오기;

    software.amazon.kinesis.producer.Metric 가져오기;

    com.amazonaws.services.kinesis.producer.ProcessFailureBehavior 가져오기;

    software.amazon.kinesis.producer.ProcessFailureBehavior 가져오기;

    com.amazonaws.services.kinesis.producer.UnexpectedMessageException 가져오기;

    software.amazon.kinesis.producer.UnexpectedMessageException 가져오기;

    com.amazonaws.services.kinesis.producer.UserRecord 가져오기;

    software.amazon.kinesis.producer.UserRecord 가져오기;

    com.amazonaws.services.kinesis.producer.UserRecordFailedException 가져오기;

    software.amazon.kinesis.producer.UserRecordFailedException 가져오기;

    com.amazonaws.services.kinesis.producer.UserRecordResult 가져오기;

    software.amazon.kinesis.producer.UserRecordResult 가져오기;

    com.amazonaws.services.kinesis.producer.protobuf.Messages 가져오기;

    software.amazon.kinesis.producer.protobuf.Messages 가져오기;

    com.amazonaws.services.kinesis.producer.protobuf.Config 가져오기;

    software.amazon.kinesis.producer.protobuf.Config 가져오기;

  4. AWS 자격 증명 공급자 클래스의 가져오기 문 업데이트

    KPL 1.x로 마이그레이션할 때 AWS SDK for Java 1.x를 기반으로 하는 KPL 애플리케이션 코드의 가져오기 패키지 및 클래스를 AWS SDK for Java 2.x 기반의 해당 패키지 및 클래스로 업데이트해야 합니다. KPL 애플리케이션의 일반적인 가져오기는 자격 증명 공급자 클래스입니다. 자격 증명 공급자 변경 사항의 전체 목록은 AWS SDK for Java 2.x 마이그레이션 가이드 설명서의 Credentials provider changes 섹션을 참조하세요. 다음은 KPL 애플리케이션에서 수행해야 할 수 있는 일반적인 가져오기 변경 사항입니다.

    KPL 0.x에서 가져오기

    import com.amazonaws.auth.DefaultAWSCredentialsProviderChain;

    KPL 1.x에서 가져오기

    import software.amazon.awssdk.auth.credentials.DefaultCredentialsProvider;

    AWS SDK for Java 1.x를 기반으로 다른 자격 증명 공급자를 가져오는 경우 AWS SDK for Java 2.x에 해당하는 자격 증명 공급자로 업데이트해야 합니다. AWS SDK for Java 1.x에서 클래스/패키지를 가져오지 않은 경우 이 단계를 무시할 수 있습니다.

  5. KPL 구성에서 자격 증명 공급자 구성 업데이트

    KPL 1.x의 자격 증명 공급자 구성에는 AWS SDK for Java 2.x 자격 증명 공급자가 필요합니다. 기본 자격 증명 공급자를 재정의 하여 KinesisProducerConfiguration의 AWS SDK for Java 1.x에 대한 자격 증명 공급자를 전달하는 경우 AWS SDK for Java 2.x 자격 증명 공급자로 업데이트해야 합니다. 자격 증명 공급자 변경 사항의 전체 목록은 AWS SDK for Java 2.x 마이그레이션 가이드 설명서의 Credentials provider changes 섹션을 참조하세요. KPL 구성에서 기본 자격 증명 공급자를 재정의하지 않은 경우 이 단계를 무시할 수 있습니다.

    예를 들어, 다음 코드로 KPL의 기본 자격 증명 공급자를 재정의하는 경우:

    KinesisProducerConfiguration config = new KinesisProducerConfiguration();
// SDK v1 default credentials provider
config.setCredentialsProvider(new DefaultAWSCredentialsProviderChain());

    AWS SDK for Java 2.x 자격 증명 공급자를 사용하려면 다음 코드로 업데이트해야 합니다.

    KinesisProducerConfiguration config = new KinesisProducerConfiguration();
// New SDK v2 default credentials provider
config.setCredentialsProvider(DefaultCredentialsProvider.create());