Struct ConsumerConfig 

pub struct ConsumerConfig {
    pub topic: String,
    pub consumer_name: String,
    pub subscription: String,
    pub subscription_type: SubscriptionType,
    pub expected_schema_subject: Option<String>,
}

Configuration for a Danube consumer

Mandatory public API - required by SinkConnector::consumer_configs() trait.

Specifies how to create a consumer for a specific topic, including subscription settings.

Fields

topic: String

Danube topic to consume from (format: /{namespace}/{topic_name})

consumer_name: String

Consumer name (for identification)

subscription: String

Subscription name (shared across consumer instances)

subscription_type: SubscriptionType

Subscription type (Exclusive, Shared, FailOver)

expected_schema_subject: Option<String>

Optional: Expected schema subject for validation If set, runtime will validate that incoming messages match this schema

Trait Implementations

impl Clone for ConsumerConfig

fn clone(&self) -> ConsumerConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerConfig

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

Formats the value using the given formatter.