TopicRouter

constructor(types: Set<AggregateType>, topic: String, partitions: Int, producer: TopicProducer)