diff --git a/pom.xml b/pom.xml index 8ef9e3749..7cd9a92d4 100644 --- a/pom.xml +++ b/pom.xml @@ -171,11 +171,6 @@ aws-java-sdk-core 1.12.782 - - com.amazonaws - amazon-kinesis-producer - 0.14.0 - javax.xml.bind jaxb-api @@ -316,9 +311,9 @@ ${aws-java.version} - com.amazonaws + software.amazon.kinesis amazon-kinesis-producer - 0.15.12 + 1.0.4 javax.xml.bind @@ -343,7 +338,7 @@ com.google.protobuf protobuf-java - 3.25.5 + 4.29.0 io.dropwizard.metrics diff --git a/src/main/java/com/zendesk/maxwell/producer/MaxwellKinesisProducer.java b/src/main/java/com/zendesk/maxwell/producer/MaxwellKinesisProducer.java index 07489cf17..794170791 100644 --- a/src/main/java/com/zendesk/maxwell/producer/MaxwellKinesisProducer.java +++ b/src/main/java/com/zendesk/maxwell/producer/MaxwellKinesisProducer.java @@ -18,15 +18,15 @@ import com.zendesk.maxwell.replication.Position; import com.zendesk.maxwell.row.RowMap; -import com.amazonaws.services.kinesis.producer.Attempt; -import com.amazonaws.services.kinesis.producer.KinesisProducer; -import com.amazonaws.services.kinesis.producer.KinesisProducerConfiguration; -import com.amazonaws.services.kinesis.producer.UserRecordFailedException; -import com.amazonaws.services.kinesis.producer.UserRecordResult; - import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import software.amazon.kinesis.producer.Attempt; +import software.amazon.kinesis.producer.KinesisProducer; +import software.amazon.kinesis.producer.UserRecordFailedException; +import software.amazon.kinesis.producer.UserRecordResult; +import software.amazon.kinesis.producer.KinesisProducerConfiguration; + class KinesisCallback implements FutureCallback { public static final Logger logger = LoggerFactory.getLogger(KinesisCallback.class); diff --git a/src/test/java/com/zendesk/maxwell/producer/KinesisCallbackTest.java b/src/test/java/com/zendesk/maxwell/producer/KinesisCallbackTest.java index 6f32c68b0..d9ff2aa2b 100644 --- a/src/test/java/com/zendesk/maxwell/producer/KinesisCallbackTest.java +++ b/src/test/java/com/zendesk/maxwell/producer/KinesisCallbackTest.java @@ -2,12 +2,12 @@ import com.codahale.metrics.Counter; import com.codahale.metrics.Meter; -import com.amazonaws.services.kinesis.producer.IrrecoverableError; import com.zendesk.maxwell.MaxwellConfig; import com.zendesk.maxwell.MaxwellContext; import com.zendesk.maxwell.replication.BinlogPosition; import com.zendesk.maxwell.replication.Position; import org.junit.Test; +import software.amazon.kinesis.producer.IrrecoverableError; import static org.mockito.Mockito.*;