connectors/karya.connectors.kafka/KafkaConnectorFactory

KafkaConnectorFactory

object KafkaConnectorFactory

Factory object for creating instances of KafkaConnector.

Functions

Link copied to clipboard
fun build(configMap: Map<*, *>): Connector<Action.KafkaProducerRequest>

Builds a KafkaConnector using the provided configuration map.

Link copied to clipboard
fun provideKafkaProducer(config: KafkaConnectorConfig): KafkaProducer<String, String>

Provides a KafkaProducer using the provided KafkaConnectorConfig.