Kafka Streams runner: stateful ParDo and user timers
维护者通常 1 天内回复
还没有人认领这个 Issue。
评估
- 难度
- 5/5
- 预计耗时
- 一周以上
- 新手友好度
- 35/100
- Issue 类型
- 功能
- 描述清晰度
- 基本清楚
- 活跃度
- 冷清
- 技术栈
- java, kafka
调研方向
从 KafkaStreamsStateInternals 和 KafkaStreamsTimerInternals 开始，然后使用 StateRequestHandler.unsupported() 且不使用 timer receivers，跟踪 Kafka Streams runner 的各个阶段。检查已排除的 @ValidatesRunner 类别以及现有的 windowed GroupByKey state-store 行为。完成标准是支持 ParDo 中的用户状态和 timers，包括 keyed input 处理，并启用列出的验证类别。
由索引模型根据 Issue 内容生成。
描述
The Kafka Streams runner does not support user state or user timers in ParDo. Stages run with StateRequestHandler.unsupported() and no timer receivers, and the corresponding @ValidatesRunner categories are excluded.
This covers UsesStatefulParDo, UsesTimersInParDo, UsesTimerMap, UsesLoopingTimer, UsesProcessingTimeTimers, UsesOnWindowExpiration and the various state types.
The pieces to build on already exist: KafkaStreamsStateInternals and KafkaStreamsTimerInternals back the windowed GroupByKey over Kafka Streams state stores, and the same backing could serve user state once the harness side is wired up. Input would also have to be shuffled by key, as GroupByKey already does.
Part of #18479.
- 主要语言
- Java
- 星标
- 8.7k
- 派生
- 4.7k
- 平均合并
- 2 天 4 小时
- 30 天内合并 PR
- 278
环境准备
- 没有 Dockerfile 或 Docker Compose 文件
- 有 Pull Request 模板
- 阅读贡献指南
从这里开始
- 先读完整个 Issue，再读项目的贡献指南。
- 在 Issue 下留言说明你要接手 —— 这能避免两个人做同样的事。
- Fork 仓库，在一个分支上完成修改。
- 提交 Pull Request，并在描述里引用这个 Issue 编号。
apache/beam 的其他 Issue
-
[Feature Request]: Support Protobuf 7.x in Python SDK可能已有人在做 @sofiathoren 于 5 天前认领。 未关闭P2 python
难度 2/5 1-3 小时 新手友好度 62/100
维护者通常 1 天内回复
-
[Bug]: Row.toString throws for an ITERABLE field that is not backed by a List可能已有人在做 @PDGGK 于 66 天前认领。 未关闭java P3
难度 2/5 1-3 小时 新手友好度 76/100
维护者通常 1 天内回复
-
难度 2/5 1-3 小时 新手友好度 68/100
apache/beam#39624 · 2 个 reaction ·
维护者通常 1 天内回复
-
[Bug]: PubsubIO used in batch incorrect batch cutoff size可能已有人在做 @1fanwang 于 54 天前认领。 未关闭bug io P3 pinned pubsub
难度 2/5 1-3 小时 新手友好度 78/100
维护者通常 1 天内回复
-
build P3 sub-task
难度 1/5 1 小时以内 新手友好度 68/100
维护者通常 1 天内回复
相似的 Issue
-
[Bug] dubbo.protocol.triple.max-message-size is only read from OS environment variables可能已有人在做 @CCCLL 今天认领。 未关闭
难度 2/5 1-3 小时 新手友好度 72/100
维护者通常 1 天内回复
-
难度 2/5 1-3 小时 新手友好度 64/100
hierynomus/sshj#1070 ·
-
难度 2/5 1-3 小时 新手友好度 84/100
intellij-elixir/intellij-elixir#4492 ·
维护者通常 1 天内回复
-
bug
难度 2/5 1-3 小时 新手友好度 77/100
-
难度 2/5 1-3 小时 新手友好度 76/100
quarkiverse/quarkus-openapi-generator#1796 · 1 条评论 ·