Struct PublishKafkaConfig 

pub struct PublishKafkaConfig {
    pub connector: Template,
    pub topic: Template,
    pub key: Option<Template>,
    pub value: 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: Template

Named connector reference. A JSONLogic expression, as HttpCallConfig::connector; read it through Self::resolve_connector.

topic: Template

Target topic name, as a JSONLogic expression — so one task can route by message content, which is the ordinary Kafka pattern: {"cat": ["orders.", {"var": "data.region"}]}. Read it through Self::resolve_topic.

key: Option<Template>

The message key, as a JSONLogic expression. Read it through Self::resolve_key.

Back-compat: key_logic is kept as an alias for the pre-3.9 spelling. This field was always an expression — the rename is for consistency with the other configs, where the _logic suffix marked the twin of a static field that no longer exists.

value: Option<Template>

The message value, as a JSONLogic expression. Read it through Self::resolve_value.

Back-compat: value_logic is kept as an alias, as for Self::key.

Implementations

impl PublishKafkaConfig

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

Resolve the connector name for this message.

Errors

As resolve_opt_string.

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

Resolve the target topic for this message.

Errors

As resolve_opt_string.

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

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

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. 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.