我尝试创建一个kafka消费者流，它的Source类型为Source<ConsumerMEssage.CommittableMessage<String,String>, Consumer.Control。
从这个源代码中，我想根据一些 predicate 使用不同的路径。因此，我想使用divertTo方法，有时也使用alsoTo方法。
这两个方法都接受一个Sink。我的问题是，当我构建这个Sink时，我希望Sink具有由源提供的具体化值类型Consumer.Control。我现在要做的是构建这样的Sink

private Sink<SomeType, NotUsed> sinkForPathA(){
  Flow.of(SomeType.class)
    .to(Committer.sink(committerSettings));
}

正如你可能注意到的，物化的值类型现在是NotUsed，这是不需要的。

private Sink<SomeType, Consumer.DrainingControl> sinkForPathA(){
  Flow.of(SomeType.class)
    .toMat(Committer.sink(committerSettings),Consumer::createDrainingControl);
}

是否有可能创建一个具有预定义物化值类型的Flow，而不仅仅是NotUsed？