小编mar*_*kin的帖子

我有以下域对象：

@Document
class Foo {
    @Id
    private final String bar;
    private final String baz;
    // getters, setters, constructor omitted
}

插入如下：

Collection<Foo> foos = ...;
mongoTemplate.insert(foos, Foo.class);

如何在一次调用中保存所有结果，忽略所有重复的键异常？

我使用 Apache Beam KafkaIO 作为我的管道源。

我需要读取两个 Kafka 主题 topic1 和 topic2，然后将此输入作为一个加入到后续转换中。

问题是 topic1 和 topic2 包含具有不兼容方案的消息，当我阅读时，我会将每个主题的消息映射到相同的方案。

所以我想要的管道看起来像这样：

<read topic1>       <read topic2>     
     |                   |
<map to Foo>        <map to Foo>
     |                   |
      \                 /
<use same subsequent transforms on Foo>

我发现解决这个问题的一种方法是使用一次订阅多个主题，withTopics(...)然后确定KafkaRecord<K,V>消息来自哪个主题，然后为其执行映射。

这看起来有点笨拙？在 Apache Beam 中有正确的方法吗？

我从服务中返回了以下json:

{
"html": "<iframe width=\"480\" height=\"270\" src=\"https://www.youtube.com/embed/FQpUOimNvXA?feature=oembed\" frameborder=\"0\" allowfullscreen></iframe>"
}

我怎样才能获得src属性值,即https://www.youtube.com/embed/FQpUOimNvXA?feature=oembed使用javascript？

我有网域：

class Company {
    List<Job> jobs;
}

有没有一种方法可以从集合中返回嵌套对象，例如：

@Repository
public interface CompanyRepository extends MongoRepository<Company, String>{
    Job findByJobId(String jobId);
}