有没有一种方法可以进行类似分支的操作，但将记录放在谓词计算为true的每个输出流中？分支将记录放到第一个匹配项(文档:在第一个匹配项上，一条记录被放置到且只有一个输出流)。
浏览 29提问于2019-01-06得票数 2
回答已采纳
"data": "blablabla"}{"storeid": 18, "data": "bliblibli"}
我需要的是将新事件发布到另一个主题/流中，当1000个事件或5分钟(这是第一次)传递时，包含相同存储区的合并数据。
浏览 4提问于2022-06-26得票数 0
1回答
卡夫卡流图()内如何等待未来？
、、、、
我正在Java中实现Spring应用程序，使用Spring和Kafka流绑定器。public Consumer<KStream<?, ?我承受不起信息丢失，把它发送到一个死信的主题不是一个选择。
是否有更好的方法阻止map()内部
浏览 3提问于2022-02-11得票数 -1
回答已采纳
1回答
流中的错误处理
、、、
我正在使用和Kafka流。假设我有一个处理器，它是一个将字符串的KStream转换为KStream of CityProgrammes的函数。现在的问题是，在转换过程中发生任何错误，整个应用程序将停止。我想向DLQ发送一个特定的信息，然后继续前进。我已经读了好几天了，每个人都建议在被调用的服务中处理错误，但在我看来，这是不可靠的，而且我仍然需要返回一个KStream:我如何在捕获范围内做到这一点？这听起来可能是一个a问题，所以问题被改写了:当出现异常并将无效项发送到DL
浏览 2提问于2021-08-25得票数 1
回答已采纳
我有一个源CSV文件，包含不同大小的记录，将每条记录推入一个源主题。我想把记录分成不同的KStreams/KTables与那个源主题。我有一个用于一个表加载的管道，在该管道中，我以分隔格式将记录从源主题推入stream1，然后将记录按AVRO格式推到另一个流中，然后将该流推入JDBC接收器连接器，该连接器将记录推入MySQL数据库。但我希望将不同表的记录
浏览 1提问于2020-04-13得票数 0
回答已采纳
1回答
当使用leftJoin方法KStream时，其中一个主题可以没有问题(次要主题)，但是当主主题下降时，不会将任何内容发送到输出主题。这似乎是因为，根据的说法，
因此，如果没有来自主流的记录，即使它们存在，它也不会使用来自次流的记录。一旦主流恢复联机，输出将恢复正常。我还尝试使用outerJoin (添加重复记录)，然后转换为KTabl
浏览 2提问于2016-11-24得票数 12
回答已采纳
1回答
我想确认我对从一个Kafka流源读取多个处理器的效率的理解。我相信，在示例1中，如果我希望根据谓词逻辑执行两个不同的进程，那么下面的示例1是最有效的。示例1public Function<KStream<String, Notification>,KStream<String, Notification>> process1() {->.........; //different additional processing to map to En
浏览 1提问于2020-08-28得票数 0
e.getMessage()) ; }); }
public Function<KStream<String, Transaction>, });
} 如果我发送状态未知的事务，StreamThr
浏览 65提问于2021-01-14得票数 0
乍一看，在我看来，使用KStream#reduceByKey可以实现与KStream to KTable leftJoin相同的功能。也就是用相同的键组合记录。我有什么区别，两者之间，也在性能方面？
浏览 0提问于2016-09-11得票数 2
回答已采纳
我有一个很大的json，它来自一个kafka主题，我正在将这个主题转换成一个Java对象，以提取我在find中需要的值。其中一些记录将有一系列缺陷，我需要捕获这些缺陷并将它们发送到不同的主题中，这样它们就可以在DB中自己的表中结束。值正在使用接收器连接器插入到DB中，这就是我们使用多个主题的原因。我已经找到了分支和拆分，但这似乎更多地用于确定使用的记录应该指向哪个主题，而不是将记录的不同部分发送到不同的主题。有没有办
浏览 3提问于2022-03-03得票数 0
在执行KStream - KTable左联接时，如果右表不匹配，则我希望将记录发回相同的主题，X秒后再发送。
这能用DSL实现吗？
浏览 0提问于2019-02-22得票数 0
回答已采纳
1回答
var streamsBuilder = new StreamsBuilder(); inputStream.mapValues((ValueMapper第一个bean将打开大小写并将结果写入某个主题('upper_case_to
浏览 5提问于2021-07-20得票数 2
回答已采纳
1回答
假设我有多个应用相同谓词集的源流。我希望设置分支流，以便满足谓词的记录，无论哪个源流，都由同一个分支流处理。如下图所示，每个分支流都像一个通用处理器，它转换传入记录。
将源流连
浏览 0提问于2018-11-24得票数 0
回答已采纳
1回答
是否在Kafka流中内置了允许将单个输入流动态连接到多个输出流的功能？KStream.branch允许基于真/假谓词进行分支，但这不是我想要的。我希望每个传入的日志都确定它在运行时将流到的主题，例如，一个日志{"date": "2017-01-01"}将流到主题topic-2017-01-01，一个日志{"date": "2017-01-02"}
浏览 2提问于2017-01-22得票数 14
回答已采纳
我不确定卡夫卡流是否是我想要解决的问题的正确解决方案。我希望能够使用它，因为它提供了并行性和容错性，但我很难找到一种方法来实现所需的处理流水线。
Serde<String> stringSerd
浏览 0提问于2018-11-17得票数 1
回答已采纳
2回答
我正在处理一个我已经创建了管道的用例，该管道将数据从mongo发送到elasticsearch。Mongo -> Spring Boot -> Kafka -> Transformer(KStream) -> Kafka ->消费者(发送给弹性搜索) 我必须计算从Mongo到Elastic search的记录所用的时间。我可以从生产者发送标题，但如何从Kafka流发送相同的标题。在下面的代码中，我想要发送我在使用inTopic时获得的头部，并将它们发送到ou
浏览 23提问于2019-04-28得票数 1
1回答
我有一个主主题和多个谓词，每个谓词都有一个与其关联的输出主题。我希望将每条记录发送到谓词解析为true的所有主题。我使用Luwak测试记录满足的谓词(要使用这个库，您可以使用一个带有谓词列表的文档，并告诉您匹配的文档-也就是说，我只调用它一次以获得满意的谓词列表)。我试图在KStream上使用Kafka流，但似乎没有合适的方法(KStream#branch只将记录路由到单个主题)。
浏览 3提问于2017-02-22得票数 10
回答已采纳
1回答
我知道Kafka允许基于指定谓词将数据分发到多个主题，而且Kafka绑定器使用@StreamListener和functional binding方法都支持这一点。.我想知道如何在返回数据之前转换其中一个分支的键或值。比方说，我想让其中一个分支拥有与其他分支不同的钥匙类型。((k, v) -> v.importantValue)
浏览 1提问于2021-04-02得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
