Remove Kinesis producer's internal TTL by default

zendesk · Jan 3, 2025 · cac143a · cac143a
1 parent ba57945
commit cac143a
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/kinesis-producer-library.properties.example b/kinesis-producer-library.properties.example
@@ -258,7 +258,7 @@ RecordMaxBufferedTime = 100
 # Default: 30000
 # Minimum: 100
 # Maximum (inclusive): 9223372036854775807
-RecordTtl = 30000
+RecordTtl = 3600000
 
 # Which region to send records to.
 #

diff --git a/src/main/java/com/zendesk/maxwell/producer/MaxwellKinesisProducer.java b/src/main/java/com/zendesk/maxwell/producer/MaxwellKinesisProducer.java
@@ -112,7 +112,9 @@ public MaxwellKinesisProducer(MaxwellContext context, String kinesisStream) {
 			KinesisProducerConfiguration config = KinesisProducerConfiguration.fromPropertiesFile(path.toString());
 			this.kinesisProducer = new KinesisProducer(config);
 		} else {
-			this.kinesisProducer = new KinesisProducer();
+			KinesisProducerConfiguration config = new KinesisProducerConfiguration();
+			config.setRecordTtl(3600000);
+			this.kinesisProducer = new KinesisProducer(config);
 		}
 	}