Package-level declarations
Types
Link copied to clipboard
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>