获取文件夹内容时发生错误.
派生自
oss-mirrors / ICV / kafka
源项目有可见性限制。
Guozhang Wang
编辑于
When store changelog reader is called by a different thread than the stream thread, it can no longer use the main consumer to get committed offsets since consumer is not thread-safe. Instead, we would remove main consumer and leverage on the existing admin client to get committed offsets. Reviewers: Bruno Cadonna <cadonna@apache.org>
名称 | 最后提交 | 最后更新 |
---|