KAFKA-10199: Remove call to Task#completeRestoration from state updater (#12379)
The call to Task#completeRestoration calls methods on the main consumer. The state updater thread should not access the main consumer since the main consumer is not thread-safe. Additionally, Task#completeRestoration changed the state of active tasks, but we decided to keep task life cycle management outside of the state updater. Task#completeRestoration should be called by the stream thread on restored active tasks returned by the state udpater. Reviewer: Guozhang Wang <guozhang@apache.org>
显示
- streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java 2 个添加, 11 个删除...afka/streams/processor/internals/DefaultStateUpdater.java
- streams/src/test/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdaterTest.java 7 个添加, 24 个删除.../streams/processor/internals/DefaultStateUpdaterTest.java
加载中
想要评论请 注册 或 登录