connectors/karya.connectors.kafka/KafkaConnector

KafkaConnector

class KafkaConnector @Inject constructor(kafkaProducer: KafkaProducer<String, String>) : Connector<Action.KafkaProducerRequest>

Connector implementation for sending messages to Kafka topic.

Constructors

Link copied to clipboard
@Inject
constructor(kafkaProducer: KafkaProducer<String, String>)

Functions

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

Sends a message to the specified Kafka topic.

Link copied to clipboard
open suspend override fun shutdown()