connectors/karya.connectors.kafka/KafkaConnector/invoke

invoke

open suspend override fun invoke(planId: UUID, action: Action.KafkaProducerRequest): ExecutorResult

Sends a message to the specified Kafka topic.

Return

The result of the execution.

Parameters

planId

The ID of the plan.

action

The action containing the Kafka request details.