apache-kafka-streams
-
Kafka 流状态存储 rocksdb 文件大小不会因手动删除消息而减少
-
使用带有 Gson 的 mapValue() 方法的 Kafka-streams 应用程序错误
-
从多个用户线程访问 ProcessContext::forward
-
了解创建的 StreamProcessor 实例数以及流任务是否共享同一个流处理器实例？
-
Kafka Streams State Stores 是处理大量密钥和数据的有状态应用程序的有效解决方案吗？
-
使用每个请求在 gRPC 客户端中打开和关闭通道
-
具有单个分区的 Kafka Streams 在出错时暂停
-
当我使用多个流时，Kafka Streams StreamsException
-
Kafka Streams - RocksDB - 最大打开文件数
-
如何一起对 Kafka Streams 和 Producer API 进行单元测试
-
Plain Producer 的自定义分区 |卡夫卡流
-
Kafka Stream - 只有一个实例从分区读取
-
如果重新分区的密钥与状态存储密钥不同，Kstreams 应用程序的多个实例是否会处理有状态数据？
-
Kafka Streams - 抑制直到 Window 结束（不关闭）
-
java.lang.ClassCastException: class .$Proxy143 无法转换为 class .MessageChannel（...在加载器 'app' 的未命名模块中）
-
Kafka 流测试：java.util.NoSuchElementException：未初始化的主题："output_topic_name"
-
如何在 Kafka Streams 中为不同的处理器使用不同的 serdes？
-
来自不同 Kafka 主题的事件数量的聚合（求和）
-
如何跳过 KafkaStreams API 中的 Avro 序列化异常？
-
Kafka：消费者api：如果在一个组中运行（顺序），回归测试失败