Struct RivvenTopicSpec 

pub struct RivvenTopicSpec {
    pub cluster_ref: ClusterReference,
    pub partitions: i32,
    pub replication_factor: i32,
    pub config: TopicConfig,
    pub acls: Vec<TopicAcl>,
    pub delete_on_remove: bool,
    pub topic_labels: BTreeMap<String, String>,
}

RivvenTopic custom resource for declarative topic management

This CRD allows users to define topics as Kubernetes resources, enabling GitOps workflows for topic lifecycle management.

Example

apiVersion: rivven.hupe1980.github.io/v1alpha1
kind: RivvenTopic
metadata:
  name: orders-events
  namespace: production
spec:
  clusterRef:
    name: my-rivven-cluster
  partitions: 12
  replicationFactor: 3
  config:
    retentionMs: 604800000   # 7 days
    cleanupPolicy: delete
    compressionType: lz4
  acls:
    - principal: "user:order-service"
      operations: ["Read", "Write"]
    - principal: "user:analytics"
      operations: ["Read"]

Fields

cluster_ref: ClusterReference

Reference to the RivvenCluster this topic belongs to

partitions: i32

Number of partitions for the topic (1-10000) Cannot be decreased after creation

replication_factor: i32

Replication factor for the topic (1-10) Must not exceed the number of brokers in the cluster

config: TopicConfig

Topic configuration parameters

acls: Vec<TopicAcl>

Access control list entries for the topic

delete_on_remove: bool

Whether to delete the topic from Rivven when the CRD is deleted Default: true (topic is deleted when CRD is removed)

topic_labels: BTreeMap<String, String>

Labels to apply to the topic metadata

Trait Implementations

impl Clone for RivvenTopicSpec

fn clone(&self) -> RivvenTopicSpec

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RivvenTopicSpec

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RivvenTopicSpec

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl JsonSchema for RivvenTopicSpec

fn schema_name() -> String

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn is_referenceable() -> bool

Whether JSON Schemas generated for this type should be re-used where possible using the $ref keyword.

impl Serialize for RivvenTopicSpec

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Validate for RivvenTopicSpec

fn validate(&self) -> Result<(), ValidationErrors>

impl<'v_a> ValidateArgs<'v_a> for RivvenTopicSpec

type Args = ()

fn validate_with_args(&self, args: Self::Args) -> Result<(), ValidationErrors>