KafkaTopicMaxRetentionMs

This transformation can be used to enforce a maximum value for the retention.ms property of kafka topics.

Configuration

Name	Type	Description	Default
`maxRetentionMs`	Int	Minimum value of `retention.ms` to be used for Kafka Topics

Example

jikkou {
  transformations: [
    {
      type = io.streamthoughts.jikkou.kafka.transform.KafkaTopicMinRetentionMsTransformation
      priority = 100
      config = {
        maxRetentionMs = 2592000000 # 30 days
      }
    }
  ]
}

Last modified November 22, 2023: refactor(core): refactor the ExtensionProvider api (ea44e963)