派生自
oss-mirrors / ICV / kafka
源项目有可见性限制。
Jason Gustafson
编辑于
This patch fixes some strangeness and inconsistency in the messages written by `TransactionalMessageCopier` to stdout. Here is a sample of two messages. Progress message: ``` {"consumed":33000,"stage":"ProcessLoop","totalProcessed":33000,"progress":"copier-0","time":"2022/04/24 05:40:31:649","remaining":333} ``` The `transactionalId` is set to the value of the `progress` key. And a shutdown message: ``` {"consumed":33333,"shutdown_complete":"copier-0","totalProcessed":33333,"time":"2022/04/24 05:40:31:937","remaining":0} ``` The `transactionalId` this time is set to the `shutdown_complete` key and there is no `stage` key. In this patch, we change the following: 1. Use a separate key for the `transactionalId`. 2. Drop the `progress` and `shutdown_complete` keys. 3. Use `stage=ShutdownComplete` in the shutdown message. 4. Modify `transactional_message_copier.py` system test service accordingly. Reviewers: David Arthur <mumrah@gmail.com>
名称 | 最后提交 | 最后更新 |
---|---|---|
.. |