Struct PublishKafkaConfig 

pub struct PublishKafkaConfig {
    pub connector: String,
    pub topic: String,
    pub key_logic: Option<Template>,
    pub value_logic: Option<Template>,
}

Configuration for the publish_kafka integration function.

The actual Kafka producer is provided by the service layer via AsyncFunctionHandler.

Unknown keys are rejected, as for HttpCallConfig.

Fields

connector: String

Named connector reference

topic: String

Target topic name

key_logic: Option<Template>

JSONLogic expression to compute the message key. Compiled once at engine construction; read it through PublishKafkaConfig::resolve_key.

value_logic: Option<Template>

JSONLogic expression to compute the message value. Compiled once at engine construction; read it through PublishKafkaConfig::resolve_value.

Implementations

impl PublishKafkaConfig

pub fn resolve_key(&self, ctx: &TaskContext<'_>) -> Result<Option<String>>

Resolve the message key from key_logic. Ok(None) when it is not set — there is no static key field, so a None key is the caller’s to interpret (Kafka treats a null key as “partition round-robin”).

Coerced to a plain string, matching HttpCallConfig::resolve_path.

Errors

As HttpCallConfig::resolve_path.

pub fn resolve_value(&self, ctx: &TaskContext<'_>) -> Result<Option<Value>>

Resolve the message value from value_logic. Ok(None) when it is not set — the fallback (typically “serialize the whole message”) stays the caller’s policy.

Returns Option<Value>, not Option<String>, deliberately: a producer that does serde_json::to_string unconditionally would put different bytes on the wire for a string-valued payload than Self::resolve_key’s plain-string coercion does. Keeping this as a Value leaves that choice where it belongs.

Errors

As HttpCallConfig::resolve_path.

Trait Implementations

impl Clone for PublishKafkaConfig

fn clone(&self) -> PublishKafkaConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PublishKafkaConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PublishKafkaConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.