wowPartitionedSource

@Bean(destroyMethod = "")
@ConditionalOnMissingBean(value = [PartitionedSource::class])
fun wowPartitionedSource(transport: TopicTransport): PartitionedSource