connectors/karya.connectors.kafka

Package-level declarations

Types

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

Connector implementation for sending messages to Kafka topic.

Link copied to clipboard
data class KafkaConnectorConfig(val bootstrapServers: String)

Configuration class for the KafkaConnector.

Link copied to clipboard
object KafkaConnectorFactory

Factory object for creating instances of KafkaConnector.