KafkaCluster
constructor(kafkaConfigMap: KafkaConfigMap, pollDuration: Duration, schemaRegistryUrl: String? = null, transactionalIdPrefix: String? = null, groupId: String = "xtdb", coroutineContext: CoroutineContext = Dispatchers.Default)