Migrieren Sie von KPL 0.x zu KPL 1.x - Amazon Kinesis Data Streams

Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Migrieren Sie von KPL 0.x zu KPL 1.x

Dieses Thema enthält step-by-step Anweisungen zur Migration Ihres Verbrauchers von KPL 0.x zu KPL 1.x. KPL 1.x bietet Unterstützung für AWS SDK for Java 2.x unter Beibehaltung der Schnittstellenkompatibilität mit früheren Versionen. Sie müssen Ihre zentrale Datenverarbeitungslogik nicht aktualisieren, um auf KPL 1.x zu migrieren.

  1. Stellen Sie sicher, dass Sie die folgenden Voraussetzungen erfüllen:

    • Java Development Kit (JDK) 8 oder höher

    • AWS SDK for Java 2.x

    • Maven oder Gradle für das Abhängigkeitsmanagement

  2. Fügen Sie Abhängigkeiten hinzu

    Wenn Sie Maven verwenden, fügen Sie Ihrer Datei pom.xml die folgende Abhängigkeit hinzu. Stellen Sie sicher, dass Sie die groupId von com.amazonaws bis software.amazon.kinesis und die Version 1.x.x auf die neueste KPL-Version aktualisiert haben. 

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

    Wenn Sie Gradle verwenden, fügen Sie Ihrer Datei Folgendes hinzu. build.gradle Stellen Sie sicher, dass Sie es 1.x.x durch die neueste KPL-Version ersetzen. 

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

    Sie können im Maven Central Repository nach der neuesten Version der KPL suchen.

  3. Aktualisieren Sie die Importanweisungen für KPL

    KPL 1.x verwendet AWS SDK for Java 2.x und verwendet einen aktualisierten Paketnamen, der mit beginntsoftware.amazon.kinesis, verglichen mit dem Paketnamen in der vorherigen KPL, der mit beginnt. com.amazonaws.services.kinesis

    Ersetzen Sie den Import für durch. com.amazonaws.services.kinesis software.amazon.kinesis In der folgenden Tabelle sind die Importe aufgeführt, die Sie ersetzen müssen.

    Importiere Ersatzprodukte
    Ersetzen Sie: mit:

    com.amazonaws.services.kinesis.producer.Attempt importieren;

    software.amazon.kinesis.producer.Attempt importieren;

    importiere com.amazonaws.services.kinesis.producer. BinaryToHexConverter;

    software.amazon.kinesis.producer importieren. BinaryToHexConverter;

    importiere com.amazonaws.services.kinesis.producer. CertificateExtractor;

    software.amazon.kinesis.producer importieren. CertificateExtractor;

    com.amazonaws.services.kinesis.producer.Daemon importieren;

    software.amazon.kinesis.producer.Daemon importieren;

    com.amazonaws.services.kinesis.producer importieren. DaemonException;

    software.amazon.kinesis.producer importieren. DaemonException;

    importiere com.amazonaws.services.kinesis.producer. FileAgeManager;

    software.amazon.kinesis.producer importieren. FileAgeManager;

    importiere com.amazonaws.services.kinesis.producer. FutureTimedOutException;

    software.amazon.kinesis.producer importieren. FutureTimedOutException;

    importiere com.amazonaws.services.kinesis.producer. GlueSchemaRegistrySerializerInstance;

    software.amazon.kinesis.producer importieren. GlueSchemaRegistrySerializerInstance;

    importiere com.amazonaws.services.kinesis.producer. HashedFileCopier;

    software.amazon.kinesis.producer importieren. HashedFileCopier;

    importiere com.amazonaws.services.kinesis.producer. IKinesisProduzent;

    software.amazon.kinesis.producer importieren. IKinesisProduzent;

    importiere com.amazonaws.services.kinesis.producer. IrrecoverableError;

    software.amazon.kinesis.producer importieren. IrrecoverableError;

    importiere com.amazonaws.services.kinesis.producer. KinesisProducer;

    software.amazon.kinesis.producer importieren. KinesisProducer;

    importiere com.amazonaws.services.kinesis.producer. KinesisProducerConfiguration;

    software.amazon.kinesis.producer importieren. KinesisProducerConfiguration;

    importiere com.amazonaws.services.kinesis.producer. LogInputStreamReader;

    software.amazon.kinesis.producer importieren. LogInputStreamReader;

    com.amazonaws.services.kinesis.producer.Metric importieren;

    software.amazon.kinesis.producer.Metric importieren;

    com.amazonaws.services.kinesis.producer importieren. ProcessFailureBehavior;

    software.amazon.kinesis.producer importieren. ProcessFailureBehavior;

    importiere com.amazonaws.services.kinesis.producer. UnexpectedMessageException;

    software.amazon.kinesis.producer importieren. UnexpectedMessageException;

    importiere com.amazonaws.services.kinesis.producer. UserRecord;

    software.amazon.kinesis.producer importieren. UserRecord;

    importiere com.amazonaws.services.kinesis.producer. UserRecordFailedException;

    software.amazon.kinesis.producer importieren. UserRecordFailedException;

    importiere com.amazonaws.services.kinesis.producer. UserRecordResult;

    software.amazon.kinesis.producer importieren. UserRecordResult;

    com.amazonaws.services.kinesis.producer.protobuf.Messages importieren;

    software.amazon.kinesis.producer.protobuf.Messages importieren;

    com.amazonaws.services.kinesis.producer.protobuf.config importieren;

    software.amazon.kinesis.producer.protobuf.config importieren;

  4. Importanweisungen für Anbieterklassen für Anmeldeinformationen aktualisieren AWS

    Bei der Migration zu KPL 1.x müssen Sie Pakete und Klassen in Ihren Importen in Ihrem KPL-Anwendungscode, die auf der Version AWS SDK for Java 1.x basieren, auf die entsprechenden Pakete und Klassen aktualisieren, die auf der Version 2.x basieren. AWS SDK for Java Übliche Importe in der KPL-Anwendung sind Anbieterklassen für Anmeldeinformationen. Eine vollständige Liste der Änderungen des Anmeldeinformationsanbieters finden Sie in der Dokumentation zum AWS SDK for Java 2.x-Migrationshandbuch unter Änderungen des Anmeldeinformationsanbieters. Im Folgenden finden Sie die häufigsten Importänderungen, die Sie möglicherweise in Ihren KPL-Anwendungen vornehmen müssen.

    Importieren Sie in KPL 0.x

    import com.amazonaws.auth.DefaultAWSCredentialsProviderChain;

    In KPL 1.x importieren

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

    Wenn Sie andere Anbieter für Anmeldeinformationen importieren, die auf Version AWS SDK for Java 1.x basieren, müssen Sie sie auf die entsprechenden Anbieter von AWS SDK for Java 2.x aktualisieren. Wenn Sie keine classes/packages aus Version AWS SDK for Java 1.x importiert haben, können Sie diesen Schritt ignorieren.

  5. Aktualisieren Sie die Konfiguration des Anmeldeinformationsanbieters in der KPL-Konfiguration

    Die Konfiguration des Anmeldeinformationsanbieters in KPL 1.x erfordert die Anmeldeinformationsanbieter AWS SDK for Java 2.x. Wenn Sie die Anbieter für Anmeldeinformationen für die Version AWS SDK for Java 1.x in der übergeben, KinesisProducerConfiguration indem Sie den standardmäßigen Anbieter für Anmeldeinformationen überschreiben, müssen Sie ihn mit den Anmeldeinformationsanbietern der Version 2.x aktualisieren. AWS SDK for Java Eine vollständige Liste der Änderungen des Anmeldeinformationsanbieters finden Sie in der Dokumentation zum Migrationshandbuch für AWS SDK for Java 2.x unter Änderungen des Anmeldeinformationsanbieters. Wenn Sie den standardmäßigen Anbieter für Anmeldeinformationen in der KPL-Konfiguration nicht überschrieben haben, können Sie diesen Schritt ignorieren.

    Wenn Sie beispielsweise den standardmäßigen Anbieter für Anmeldeinformationen für die KPL mit dem folgenden Code überschreiben:

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

    Sie müssen sie mit dem folgenden Code aktualisieren, um den AWS SDK for Java 2.x-Anmeldeinformationsanbieter verwenden zu können:

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