gpt4 book ai didi

java - Apache 卡夫卡 : Processor generates multiple output per input

转载 作者:行者123 更新时间:2023-11-30 02:24:24 24 4
gpt4 key购买 nike

我有一个 Kafka 流处理器,它必须将一项作为输入,并生成多项作为输出。正确的编码方法是什么?多次调用 this.context().forward(key, item) 是正确的方法吗?还是还有其他作弊方法?

谢谢。

最佳答案

对于处理器 API,context.forward(key, item) 是正确的。

对于 DSL,您还可以使用 KStream#flatMapValues()KStream()flatMap()

关于java - Apache 卡夫卡 : Processor generates multiple output per input,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/46045347/

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com