Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.
Esegui la migrazione da 0.x a 1.x KPL KPL
Questo argomento fornisce step-by-step istruzioni per migrare il consumatore da KPL 0.x a 1.x. KPL KPL1.x introduce il supporto per la versione AWS SDK for Java 2.x pur mantenendo la compatibilità dell'interfaccia con le versioni precedenti. Non è necessario aggiornare la logica di elaborazione dei dati di base per migrare alla versione 1.x. KPL
-
Assicurati di avere i seguenti prerequisiti:
-
Java Development Kit (8JDK) o versione successiva
-
AWS SDK for Java 2.x
-
Maven o Gradle per la gestione delle dipendenze
-
-
Aggiungi dipendenze
Se utilizzi Maven, aggiungi la seguente dipendenza al tuo file pom.xml. Assicurati di aver aggiornato il modulo groupId
com.amazonaws
asoftware.amazon.kinesis
e la versione1.x.x
all'ultima versione. KPL<dependency> <groupId>software.amazon.kinesis</groupId> <artifactId>amazon-kinesis-producer</artifactId> <version>1.x.x</version> <!-- Use the latest version --> </dependency>
Se stai usando Gradle, aggiungi quanto segue al tuo
build.gradle
file. Assicurati di sostituirlo1.x.x
con la KPL versione più recente.implementation 'software.amazon.kinesis:amazon-kinesis-producer:1.x.x'
Puoi verificare la presenza dell'ultima versione di KPL sul Maven Central
Repository. -
Aggiorna le dichiarazioni di importazione per KPL
KPL1.x utilizza la versione AWS SDK for Java 2.x e utilizza un nome di pacchetto aggiornato che inizia con
software.amazon.kinesis
, rispetto al nome del pacchetto precedente KPL che inizia con.com.amazonaws.services.kinesis
Sostituisci l'importazione per
com.amazonaws.services.kinesis
con.software.amazon.kinesis
La tabella seguente elenca le importazioni che è necessario sostituire.Importa sostituzioni Sostituisci: Con: import com.amazonaws.services.kinesis.producer.Attempt;
importa software.amazon.kinesis.Producer.tentment;
importa com.amazonaws.services.kinesis.producer. BinaryToHexConverter;
importare software.amazon.kinesis.producer. BinaryToHexConverter;
importare com.amazonaws.services.kinesis.producer. CertificateExtractor;
importare software.amazon.kinesis.producer. CertificateExtractor;
importare com.amazonaws.services.kinesis.producer.daemon;
importare software.amazon.kinesis.Producer.daemon;
importa com.amazonaws.services.kinesis.producer. DaemonException;
importare software.amazon.kinesis.producer. DaemonException;
importare com.amazonaws.services.kinesis.producer. FileAgeManager;
importare software.amazon.kinesis.producer. FileAgeManager;
importare com.amazonaws.services.kinesis.producer. FutureTimedOutException;
importare software.amazon.kinesis.producer. FutureTimedOutException;
importare com.amazonaws.services.kinesis.producer. GlueSchemaRegistrySerializerInstance;
importare software.amazon.kinesis.producer. GlueSchemaRegistrySerializerInstance;
importare com.amazonaws.services.kinesis.producer. HashedFileCopier;
importare software.amazon.kinesis.producer. HashedFileCopier;
importare com.amazonaws.services.kinesis.producer. IKinesisProducer;
importare software.amazon.kinesis.producer. IKinesisProducer;
importare com.amazonaws.services.kinesis.producer. IrrecoverableError;
importare software.amazon.kinesis.producer. IrrecoverableError;
importare com.amazonaws.services.kinesis.producer. KinesisProducer;
importare software.amazon.kinesis.producer. KinesisProducer;
importare com.amazonaws.services.kinesis.producer. KinesisProducerConfiguration;
importare software.amazon.kinesis.producer. KinesisProducerConfiguration;
importare com.amazonaws.services.kinesis.producer. LogInputStreamReader;
importare software.amazon.kinesis.producer. LogInputStreamReader;
importare com.amazonaws.services.kinesis.producer.metric;
importare software.amazon.kinesis.producer.metric;
importa com.amazonaws.services.kinesis.producer. ProcessFailureBehavior;
importare software.amazon.kinesis.producer. ProcessFailureBehavior;
importare com.amazonaws.services.kinesis.producer. UnexpectedMessageException;
importare software.amazon.kinesis.producer. UnexpectedMessageException;
importare com.amazonaws.services.kinesis.producer. UserRecord;
importare software.amazon.kinesis.producer. UserRecord;
importare com.amazonaws.services.kinesis.producer. UserRecordFailedException;
importare software.amazon.kinesis.producer. UserRecordFailedException;
importare com.amazonaws.services.kinesis.producer. UserRecordResult;
importare software.amazon.kinesis.producer. UserRecordResult;
importare com.amazonaws.services.kinesis.producer.protobuf.messages;
importare software.amazon.kinesis.producer.protobuf.messages;
importare com.amazonaws.services.kinesis.producer.protobuf.config;
importare software.amazon.kinesis.producer.protobuf.config;
-
Aggiorna le dichiarazioni di importazione per le classi del fornitore di credenziali AWS
Quando si esegue la migrazione alla KPL 1.x, è necessario aggiornare i pacchetti e le classi importati nel codice KPL dell'applicazione basati sulla versione AWS SDK for Java 1.x con quelli corrispondenti basati sulla 2.x. AWS SDK for Java Le importazioni più comuni nell'KPLapplicazione sono le classi di provider di credenziali. Consulta le modifiche al provider di credenziali nella documentazione della guida alla migrazione AWS SDK for Java 2.x per l'elenco completo delle modifiche al provider di credenziali. Ecco le comuni modifiche di importazione che potresti dover apportare alle tue applicazioni. KPL
Importa in KPL 0.x
import com.amazonaws.auth.DefaultAWSCredentialsProviderChain;
Importa in 1.x KPL
import software.amazon.awssdk.auth.credentials.DefaultCredentialsProvider;
Se si importano altri provider di credenziali basati sulla versione AWS SDK for Java 1.x, è necessario aggiornarli con quelli equivalenti alla versione AWS SDK for Java 2.x. Se non hai importato nessuna classe/pacchetto dalla versione AWS SDK for Java 1.x, puoi ignorare questo passaggio.
-
Aggiorna la configurazione del provider di credenziali nella configurazione KPL
La configurazione del provider di credenziali in KPL 1.x richiede i provider di credenziali AWS SDK for Java 2.x. Se state passando i provider di credenziali per la versione AWS SDK for Java 1.x
KinesisProducerConfiguration
sostituendo il provider di credenziali predefinito, dovete aggiornarlo con i provider di credenziali 2.x. AWS SDK for Java Vedi Modifiche al provider di credenziali nella documentazione della guida alla migrazione AWS SDK for Java 2.x per l'elenco completo delle modifiche al provider di credenziali. Se non hai sovrascritto il provider di credenziali predefinito nella KPL configurazione, puoi ignorare questo passaggio.Ad esempio, se stai sovrascrivendo il provider di credenziali predefinito per il KPL con il codice seguente:
KinesisProducerConfiguration config = new KinesisProducerConfiguration(); // SDK v1 default credentials provider config.setCredentialsProvider(new DefaultAWSCredentialsProviderChain());
È necessario aggiornarli con il codice seguente per utilizzare il provider di credenziali AWS SDK for Java 2.x:
KinesisProducerConfiguration config = new KinesisProducerConfiguration(); // New SDK v2 default credentials provider config.setCredentialsProvider(DefaultCredentialsProvider.create());