Skip to content

Commit b267fd1

Browse files
committed
Remove Kinesis producer's internal TTL by default
1 parent ba57945 commit b267fd1

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

kinesis-producer-library.properties.example

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -258,7 +258,7 @@ RecordMaxBufferedTime = 100
258258
# Default: 30000
259259
# Minimum: 100
260260
# Maximum (inclusive): 9223372036854775807
261-
RecordTtl = 30000
261+
RecordTtl = 9223372036854775807
262262

263263
# Which region to send records to.
264264
#

src/main/java/com/zendesk/maxwell/producer/MaxwellKinesisProducer.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -112,6 +112,8 @@ public MaxwellKinesisProducer(MaxwellContext context, String kinesisStream) {
112112
KinesisProducerConfiguration config = KinesisProducerConfiguration.fromPropertiesFile(path.toString());
113113
this.kinesisProducer = new KinesisProducer(config);
114114
} else {
115+
KinesisProducerConfiguration config = new KinesisProducerConfiguration();
116+
config.setRecordTtl(Long.MAX_VALUE);
115117
this.kinesisProducer = new KinesisProducer();
116118
}
117119
}

0 commit comments

Comments
 (0)