KafkaTopicMinInSyncReplicas
This transformation can be used to enforce a minimum value for the min.insync.replicas
property of kafka topics.
Configuration
Name | Type | Description | Default |
---|---|---|---|
minInSyncReplicas | Int | Minimum value of min.insync.replicas to be used for Kafka Topics |
Example
jikkou {
transformations: [
{
type = io.streamthoughts.jikkou.kafka.transform.KafkaTopicMinInSyncReplicasTransformation
priority = 100
config = {
minInSyncReplicas = 2
}
}
]
}
Last modified November 22, 2023: refactor(core): refactor the ExtensionProvider api (ea44e963)