KabalKafkaKonsument
constructor(config: KafkaConsumerConfig, pollTimeout: Duration = 10.seconds, closeTimeout: Duration = 30.seconds, topic: String = KABAL_EVENT_TOPIC, dataSource: DataSource, repositoryRegistry: RepositoryRegistry)(source)