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.*;