删除重建Kafka Streams(ksql)后消息丢失问题求助

• 已在KSQL Server配置中设置ksql.streams.auto.offset.reset=earliest，但删除某流/表后用相同查询重建时，对应主题仅能获取新消息
• 该问题是启用ksql.streams.processing.guarantee=exactly_once_v2配置后出现的
• 直接执行以下查询语句时，可返回主题中的所有消息：

SELECT 
    STRUCT( `Id`:= ROWKEY->ID, `RoleId`:= 4) AS ROWKEY,
    BEFORE,
    AFTER,
    OP
FROM STREAM_DATACHANGES_EDITOR
WHERE (AFTER IS NOT NULL AND AFTER->STATUSID IN (1,2)) OR (OP = 'd');

内容的提问来源于stack exchange，提问作者Muhammed Rahiz