如何创建一个以collection对象为值的kstream？

kyxcudwk 于 2021-06-05 发布在 Kafka

关注(0)|答案(1)|浏览(753)

我在Spring云流Kafka流活页夹工作。在我的consumerbean方法中，我希望返回kstream，并将字符串列表作为值-

@Bean
public Function<KStream<Object, String>, KStream<String, List<String>>> method() {
        return input -> {
        /* business logic */
        return KStream<String, List<String>>;
        };
}

有没有可能有一个以collection为其值的kstream？如果是的话，有人能解释一下如何创造它吗？

apache-kafka apache-kafka-streams spring-cloud-stream java-8 spring-cloud-stream-binder-kafka

来源：https://stackoverflow.com/questions/61982814/how-to-create-a-kstream-with-a-collection-object-as-value

1条答案

按热度按时间

ffscu2ro1#

对于这个案子，你可以打电话 mapValues() :

return input -> {
    return input.mapValues(v -> {
        List<String> list = new LinkedList(); // or any other list implementation
        list.add(v); // or any other logic
        return list;
    }
};

赞(0）回复(0）举报 2021-06-06

我来回答

如何创建一个以collection对象为值的kstream？

1条答案

相关问题

热门标签

最新问答