获取文件夹内容时发生错误.
派生自
oss-mirrors / ICV / kafka
源项目有可见性限制。
Bruno Cadonna
编辑于
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>
名称 | 最后提交 | 最后更新 |
---|