Package-level declarations
Types
Link copied to clipboard
class KafkaCluster(val kafkaConfigMap: KafkaConfigMap, pollDuration: Duration, val schemaRegistryUrl: String? = null, val transactionalIdPrefix: String? = null, groupId: String = "xtdb", coroutineContext: CoroutineContext = Dispatchers.Default) : Remote