KAFKA-10199: Bookkeep tasks during assignment for use with state updater (#12442)
Bookkeeps tasks to be recycled, closed, and updated during handling of the assignment. The bookkeeping is needed for integrating the state updater. These change is hidden behind internal config STATE_UPDATER_ENABLED. If the config is false Streams should not use the state updater and behave as usual. Reviewers: Guozhang Wang <wangguoz@gmail.com>
显示
- streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java 16 个添加, 1 个删除...pache/kafka/streams/processor/internals/StreamThread.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java 106 个添加, 49 个删除...apache/kafka/streams/processor/internals/TaskManager.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/Tasks.java 21 个添加, 0 个删除...a/org/apache/kafka/streams/processor/internals/Tasks.java
- streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java 2 个添加, 2 个删除...e/kafka/streams/processor/internals/StreamThreadTest.java
- streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java 67 个添加, 25 个删除...he/kafka/streams/processor/internals/TaskManagerTest.java
- streams/src/test/java/org/apache/kafka/test/StreamsTestUtils.java 0 个添加, 23 个删除...src/test/java/org/apache/kafka/test/StreamsTestUtils.java
加载中
想要评论请 注册 或 登录