v0.1.106
What's Changed
- 现在即使没有拉取到任何数据,也一定会调用用户的消费组 process 函数,来保证 saveCheckPoint 可以被正常触发到。在规则消费场景下(即设置了 query 参数),如果所有数据都被过滤掉,返回的数据可能为空,但是消费进度仍然应该向前。这种情况下必须调用用户 process 函数来保证消费进度可以被保存。所以,process 函数目前可能会传入长度为 0 的 LogGroup 数据
Full Changelog: v0.1.103...v0.1.106