connectors/karya.connectors.kafka/KafkaConnectorFactory/provideKafkaProducer

provideKafkaProducer

fun provideKafkaProducer(config: KafkaConnectorConfig): KafkaProducer<String, String>

Provides a KafkaProducer using the provided KafkaConnectorConfig.

Return

An instance of KafkaProducer.

Parameters

config

The configuration for the KafkaConnector.