apache-kafka-streams
-
KTable中的数据保存了多长时间？
-
Kafka 比较键的连续值
-
Kafka-stream：如何通过从值列表中选择键来重新键入流
-
Kafka Stream Suppress 在窗口化后不产生输出
-
Kafka 流：class 在左连接期间抛出异常
-
如何在同一主题上使用 globalKtable 和 StateStore？
-
如何使用 Kafka Streams 对 Spring Cloud Stream 进行单元测试
-
重新启动 kafka streams 应用程序时，先前为空的分区上缺少事件
-
Kafka 流聚合抛出异常
-
KStream suppress operator如何确定一个window的最后一条记录？
-
相同键控主题无法加入 Kafka 流
-
与 AVRO 相比，在 kafka 流中使用 JSON 序列化程序是否会导致性能下降？
-
有没有办法将数据发送到主题的特定分区
-
Spring Cloud Stream 将值生成为包含 JSON 而不仅仅是 JSON 的字符串
-
Kafka：在x时间内没有更新时更新密钥
-
没有为事件到达定义时间 window 时的事件合并
-
有没有办法用 Kafka-Stream 重新计算每条消息的平均值？
-
KStream.map 中的空值导致 IllegalArgumentException：负载不得为空
-
KTable聚合转发相同的消息
-
如果会话 window 在保留期之前结束并且不活动间隙在保留期之后结束，会发生什么情况？