SourceTopics

constructor(source: PartitionedSource, prefix: String = "", producer: TopicProducer? = null, intake: Boolean = false, admin: TopicAdmin? = null, ddl: Ddl = Ddl.NONE, partitionRefresh: Duration = DEFAULT_PARTITION_REFRESH)