Skip to content

Commit 49005cf

Browse files
authored
Added split_ttl to MirrordKafkaTopicsConsumer (#3299)
1 parent ab018da commit 49005cf

File tree

2 files changed

+14
-0
lines changed

2 files changed

+14
-0
lines changed

changelog.d/+kafka-split-ttl.added.md

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
Extended the `MirrordKafkaTopicsConsumer` CRD with `split_ttl` field.

mirrord/operator/src/crd/kafka.rs

+13
Original file line numberDiff line numberDiff line change
@@ -128,6 +128,19 @@ pub struct MirrordKafkaTopicsConsumerSpec {
128128
#[serde(skip_serializing_if = "Option::is_none")]
129129
pub consumer_restart_timeout: Option<u32>,
130130

131+
/// Period of time to wait before cleaning up Kafka splits for this consumer and reverting Pod
132+
/// template patches (in seconds).
133+
///
134+
/// For any given topic, starting the first Kafka splitting session requires patching the
135+
/// target workload. Similarly, stopping the last Kafka splitting session requires another
136+
/// patch, that reverts the first one.
137+
///
138+
/// If the target workload takes a long time to restart, it may be desirable to keep the Kafka
139+
/// splits alive longer, so that the next Kafka splitting session will not have to patch
140+
/// the workload again.
141+
#[serde(skip_serializing_if = "Option::is_none")]
142+
pub split_ttl: Option<u32>,
143+
131144
/// List of consumed splittable topics.
132145
pub topics: Vec<KafkaTopicDetails>,
133146
}

0 commit comments

Comments
 (0)