sinkSupplier

open override val sinkSupplier: (NamedAggregate) -> Sinks.Many<CommandMessage<*>>

一个命令只能有一个消费者，所以使用单播模式.