Struct TopicAssignment

pub struct TopicAssignment(/* private fields */);

Configuration for a “logical” topic/datasink that Relay should forward data into.

Can be either a string containing the kafka topic name to produce into (using the default kafka_config), an object containing keys topic_name and kafka_config_name for using a custom kafka cluster, or an array of topic names/configs for sharded topics.

See documentation for secondary_kafka_configs for more information.

Implementations

impl TopicAssignment

pub fn kafka_configs<'a>( &'a self, default_config: &'a Vec<KafkaConfigParam>, secondary_configs: &'a BTreeMap<String, Vec<KafkaConfigParam>>, ) -> Result<KafkaTopicConfig<'a>, ConfigError>

Get the Kafka configs for the current topic assignment.

Errors

Returns ConfigError if the configuration for the current topic assignment is invalid.

Trait Implementations

impl Debug for TopicAssignment

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TopicAssignment

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>

where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<String> for TopicAssignment

fn from(topic_name: String) -> Self

Converts to this type from the input type.

impl Serialize for TopicAssignment

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

where __S: Serializer,

Serialize this value into the given Serde serializer.