apache-kafka-streams

英文: Kafka Stream-GlobalKTable join on a specific field 问题 以下是您要翻译的部分： 我有一个KStream，它被反序列化为一个POJO，如下所示...

英文: How to sum the values in a KTable (Kafka) 问题 我有两个KTables。一个保存我拥有的股票数量，另一个保存这些股票的最新价格。 例如， 数量 键 值...

英文: Can we do parallel Kafka Streams processing with CompletableFutures 问题 可以使用Java的CompletableFutur...

英文: Kafka Stream to consume JSON and Produce Avro 问题 请提供GitHub网址，以便我查看代码和所有需要完成的配置。提前致谢。 英文: As i am...

英文: Kafka consumer showing numbers in unreadable format 问题 以下是您提供的内容的翻译： 我正在尝试使用Kafka流处理。我正在从一个主题中读取...

英文: Kafka Streams API: Session Window incompatible types 问题 我有以下代码片段： groupedStream.windowedBy(Sessi...

英文: Spring kafka re-create Kafka Stream Topology in runtime 问题 我有一个基于Spring Boot、Spring Kafka和Kafka ...

英文: Simultaneous operations on KStream & KTables 问题 我正尝试在Kafka Streams中实现一个用例，根据对流应用某些过滤器来填充一个KT...

英文: KStreams - How to handle delay of messages on one topic 问题 I have translated the non-code part o...

英文: Kafka KStream to KStream join | restart performance 问题 我计划将两个主题作为KStreams加入到一个长窗口（约1周）中。假设在这个窗口中...