AutoMQ/automq

[BUG] In the scenario of Topic deletion, Stream Object leakage

superhx opened this issue · 0 comments

superhx commented

Problem Scenario:

  1. Start Stream Set Object compaction;
  2. Delete Topic;
  3. Trigger the deletion of the Stream: delete Stream metadata, delete Stream Objects under the Stream;
  4. Stream Set Object compaction completed, generating deleted Stream's Stream Objects.
[2024-02-19 16:31:01,254] ERROR [Controller 0] streamId=2902 not exist when replay stream object record S3StreamObjectRecord(streamId=2902, startOffset=519, endOffset=677, objectId=11870, dataTimeInMs=1708331461251) (org.apache.kafka.controller.stream.StreamControlManager)
[2024-02-19 16:31:01,252] ERROR [REPLAY_STREAM_SET_OBJECT_FAIL] cannot find streamId=3401 metadata (org.apache.kafka.controller.stream.StreamControlManager)