KabalKafkaKonsument
class KabalKafkaKonsument(config: KafkaConsumerConfig, pollTimeout: Duration = 10.seconds, closeTimeout: Duration = 30.seconds, topic: String = KABAL_EVENT_TOPIC, val dataSource: DataSource, val repositoryRegistry: RepositoryRegistry) : KafkaKonsument<String, String> (source)
Constructors
Link copied to clipboard
constructor(config: KafkaConsumerConfig, pollTimeout: Duration = 10.seconds, closeTimeout: Duration = 30.seconds, topic: String = KABAL_EVENT_TOPIC, dataSource: DataSource, repositoryRegistry: RepositoryRegistry)