CODEWITHSUNDEEP
apache-kafkaapache-kafka-streams
Abe
Abe

Reputation: 696

default max.compaction.lag.ms for changelog

I use below:

windowedBy(TimeWindows.of(Duration.ofHours(6)))
.aggregate(aggregator, aggregator,
        Materialized.as("my-agg"))

Changelog was created with below configs

    cleanup.policy = compact,delete
    retention.ms = 2d
    max.compaction.lag.ms = Infinity

What does Infinity mean? Will it be compacted or not?

Upvotes: 0

Views: 16

Answers (0)

Related Questions