KAFKA-10199: Expose tasks in state updater (#12312)
This PR exposes the tasks managed by the state updater. The state updater manages all tasks that were added to the state updater and that have not yet been removed from it by draining one of the output queues. Reviewers: Guozhang Wang <wangguoz@gmail.com>
显示
- streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java 107 个添加, 42 个删除...afka/streams/processor/internals/DefaultStateUpdater.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/StateUpdater.java 55 个添加, 6 个删除...pache/kafka/streams/processor/internals/StateUpdater.java
- streams/src/test/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdaterTest.java 274 个添加, 58 个删除.../streams/processor/internals/DefaultStateUpdaterTest.java
加载中
想要评论请 注册 或 登录