Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
如何使用 Kafka 流 DSL 函数处理重复消息
我的要求是跳过或避免使用 kafka 流 DSL API 从 INPUT 主题接收到的重复消息 具有相同的密钥 如果发生任何故障 源系统可能会向 INPUT 主题发送重复的消息 FLOW 源系统 gt 输入主题 gt Kafka Strea
apachekafkastreams
Kafka Streams 物化存储构建错误
我正在尝试在这里构建 Materialized as DSL 代码 https kafka apache org 11 javadoc org apache kafka streams state Stores html 但我收到错误 in
Java
ApacheKafka
apachekafkastreams
Kafka Streams 2.1.1 类转换,同时刷新定时聚合以存储
我正在尝试使用 kafka 流执行窗口聚合 并仅在某个会话窗口关闭后才发出结果 为了实现这一点 我使用了抑制功能 问题是我找不到一种方法来使这个简单的测试工作 因为当它尝试保持状态时 我得到一个类转换异常 因为它尝试将 Windowed 转
ApacheKafka
apachekafkastreams
Spring Cloud Kafka Streams 中的错误处理
我正在使用 Spring Cloud Stream 和 Kafka Streams 假设我有一个处理器 它是一个将字符串的 KStream 转换为 CityProgrammes 的 KStream 的函数 它调用 API 按名称查找城市 并
ApacheKafka
apachekafkastreams
springKafka
springcloudstream
使用 Kafka Streams DSL 进行两步窗口聚合
假设我有一个流 stream 1 每秒由 1 个数据点组成 我想计算一个派生流 stream 5 其中包含使用 5 秒的跳跃窗口和另一个流 stream 10 的总和它基于包含使用 10 秒跳跃窗口的总和的 stream 5 需要分别对每个
ApacheKafka
apachekafkastreams
Kafka Streams - 如何更好地控制内部创建的状态存储主题的分区?
Kafka Streams 中的状态存储是在内部创建的 状态存储按键分区 但不允许提供除by key 据我所知 问题 How to 控制状态存储内部创建主题的分区数量 状态存储主题如何推断默认情况下要使用的分区数量和分区 以及如何覆盖 如果
ApacheKafka
partitioning
apachekafkastreams
KafkaStreams:获取窗口最终结果
是否可以得到窗口最终结果在 Kafka Streams 中通过抑制中间结果 我无法实现这个目标 我的代码有什么问题吗 val builder StreamsBuilder builder stream
kotlin
ApacheKafka
apachekafkastreams
如何对使用会话窗口的 kafka 流应用程序进行单元测试
我正在使用 Kafka Stream 2 1 我正在尝试为聚合的流应用程序编写一些测试 一些事件按其键 即通过相关 ID 使用会话窗口 不活动间隙为 300 毫秒 这是由方法表示的聚合实现 private static final int
Java
unittesting
apachekafkastreams
windowing
KStream 批处理窗口
我想使用 KStream 接口批量处理消息 我有一个带有键 值的流 我尝试将它们收集在翻滚窗口中 然后我想立即处理整个窗口 builder stream longSerde updateEventSerde CONSUME TOPIC ag
Java
ApacheKafka
apachekafkastreams
如何将自定义 StateStore 添加到 Kafka Streams DSL 处理器?
对于我的 Kafka 流应用程序之一 我需要使用 DSL 和处理器 API 的功能 我的流媒体应用程序流程是 source gt selectKey gt filter gt aggregate on a window gt sink 聚合
apachekafkastreams
逻辑删除消息未从 KTable 状态存储中删除记录?
我正在创建 KTable 处理来自 KStream 的数据 但是 当我触发具有密钥和空负载的逻辑删除消息时 它不会从 KTable 中删除消息 sample public KStream
apachekafkastreams
springcloudstream
springKafka
如何仅在窗口完成时输出窗口聚合结果? [复制]
这个问题在这里已经有答案了 我有一个KStream我想在其中计算事件的某些维度 我这样做 KTable
ApacheKafka
apachekafkastreams
无法在 Kafka Stream 应用程序的 IDE 中删除状态目录
我正在开发一个简单的 Kafka Stream 应用程序 它从一个主题中提取消息并在转换后将其放入另一个主题中 我正在使用 Intelij 进行开发 当我调试 运行这个应用程序时 如果我的 IDE 和 Kafka 服务器位于同一台机器 即
Java
Windows
ApacheKafka
apachekafkastreams
Kafka Streams如何获取kafka headers
我有下面的卡夫卡流代码 public class KafkaStreamHandler implements Processor
Java
ApacheKafka
apachekafkastreams
Kafka 多分区排序
我知道在 Kafka 中不可能对多个分区进行排序 并且分区排序仅保证组内的单个消费者 对于单个分区 然而 使用 Kafka Streams 0 10 现在可以实现这一目标吗 如果我们使用时间戳功能 以便每个分区中的每条消息都保持顺序 那么在
ApacheKafka
kafkaconsumerapi
kafkaproducerapi
apachekafkastreams
«
1
2
3
4
5