xtdb-kafka/xtdb.api.log/Kafka/Factory/Factory

Factory

constructor(bootstrapServers: String, txTopic: String, filesTopic: String, autoCreateTopics: Boolean = true, txPollDuration: Duration = Duration.ofSeconds(1), filePollDuration: Duration = Duration.ofSeconds(5), propertiesMap: Map<String, String> = emptyMap(), propertiesFile: Path? = null)