We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
在使用CanalServerWithEmbedded的get方法获取数据时,会直接触发ack,但是ack的同时会执行cleanUntil,导致获取的Message中的Event.ByteString被置为null
相关代码为 Event lastEvent = entries[getIndex(next)]; lastEvent.setEntry(null); lastEvent.setRawEntry(null);
The text was updated successfully, but these errors were encountered:
MemoryEventStoreWithBuffer 存在问题,怎么解决?
Sorry, something went wrong.
现象:当拉取到的Event是多条的时候,最后一条在ack的时候数据会被置空
fixed issue #4027, CanalServerWithEmbedded.get support newList
b7eff72
No branches or pull requests
在使用CanalServerWithEmbedded的get方法获取数据时,会直接触发ack,但是ack的同时会执行cleanUntil,导致获取的Message中的Event.ByteString被置为null
相关代码为
Event lastEvent = entries[getIndex(next)];
lastEvent.setEntry(null);
lastEvent.setRawEntry(null);
The text was updated successfully, but these errors were encountered: