Akka Solr连接器

如何解决Akka Solr连接器

我正在寻找一种将对象流式传输到Solr Cloud的方法。唯一的问题是对象本身以Solr集合名称的形式包含有关其目的地的信息。而且可以有很多（30多个）目标集合。

型号：

public class Message {
   String targetCollectionName;
   Payload payload;
}

在Akka网站上找到了此示例。如果我可以从流动的对象中获取集合名称并将其发送到适当的集合，那么一切都会很棒。但是据我所知，这些管道是经过编译的，不可能。

SolrUpdateSettings settings = SolrUpdateSettings.create().withCommitWithin(5);
CompletionStage<Done> f1 = Solrsource.fromTupleStream(stream)
  .map(tuple -> {
    String title = tuple.getString("title");
    return IncomingMessage.create(new BookBean(title));
  }).runWith(
    Solrsink.bean(
      "collection3",settings,client,Book.class
    ),materializer
  );

文档对我没有多大帮助。我是否需要为每个目标集合和过滤器/路由消息预定义流？那将是一个非常丑陋的解决方案。