Skip to content

【BUG】MemoryEventStoreWithBuffer的cleanUntil存在问题 #4027

@tsinbal

Description

@tsinbal

在使用CanalServerWithEmbedded的get方法获取数据时,会直接触发ack,但是ack的同时会执行cleanUntil,导致获取的Message中的Event.ByteString被置为null

相关代码为
Event lastEvent = entries[getIndex(next)];
lastEvent.setEntry(null);
lastEvent.setRawEntry(null);

Metadata

Metadata

Assignees

No one assigned

    Labels

    Type

    No type

    Projects

    No projects

    Milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions