)]}'
{
  "commit": "1dbe5edff0e9ef09675f158cfe2b0c4bb1ee7c75",
  "tree": "aa550ee3b5a0fb14687a1c5c08fbf5bb503cd704",
  "parents": [
    "bd50ef74fb37f437d29513a9361428e41d8c0263"
  ],
  "author": {
    "name": "xwm1992",
    "email": "mike_xwm@126.com",
    "time": "Wed Aug 05 17:38:14 2026 +0800"
  },
  "committer": {
    "name": "xwm1992",
    "email": "mike_xwm@126.com",
    "time": "Wed Aug 05 17:38:14 2026 +0800"
  },
  "message": "fix(offset): unify MQ physical offset and align pull cursor to ACK offset on restart\n",
  "tree_diff": [
    {
      "type": "modify",
      "old_id": "689634286b69d1e8416e5bbaea40ba9a992f0a62",
      "old_mode": 33188,
      "old_path": "eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/UniRuntime.java",
      "new_id": "89357003149a8e6d11a1e0a8b42ef11eeee17333",
      "new_mode": 33188,
      "new_path": "eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/UniRuntime.java"
    },
    {
      "type": "modify",
      "old_id": "210b3abe7d11943ea47ce245b6ced56a2a585739",
      "old_mode": 33188,
      "old_path": "eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/cluster/MetaBackedOffsetStore.java",
      "new_id": "4adce8ac7e0ab609a41230e33e4f12368e1bda81",
      "new_mode": 33188,
      "new_path": "eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/cluster/MetaBackedOffsetStore.java"
    },
    {
      "type": "modify",
      "old_id": "d8767c3dc0e0dc4c90a5f4cfb76d1ae4adb1494b",
      "old_mode": 33188,
      "old_path": "eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/ingress/UniIngressService.java",
      "new_id": "b0a6978715a6b13eb560f0491a071243b024b9f8",
      "new_mode": 33188,
      "new_path": "eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/ingress/UniIngressService.java"
    },
    {
      "type": "modify",
      "old_id": "caae7d2aa8092931eda631c4dc83d25a86b72a9c",
      "old_mode": 33188,
      "old_path": "eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/offset/InMemoryOffsetStore.java",
      "new_id": "59359a852f71e3959910eacb4391972a0a209437",
      "new_mode": 33188,
      "new_path": "eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/offset/InMemoryOffsetStore.java"
    },
    {
      "type": "add",
      "old_id": "0000000000000000000000000000000000000000",
      "old_mode": 0,
      "old_path": "/dev/null",
      "new_id": "b81dd9dc745d41c73efd0378f9f29ca5584d9cd7",
      "new_mode": 33188,
      "new_path": "eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/offset/InMemoryPushOffsetStore.java"
    },
    {
      "type": "modify",
      "old_id": "48e013c0a7a9a9eaa594777dce9e3e1d2118309a",
      "old_mode": 33188,
      "old_path": "eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/offset/OffsetStore.java",
      "new_id": "6feb01db7e1a34f8f3042697caf4ee2db72ddc1f",
      "new_mode": 33188,
      "new_path": "eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/offset/OffsetStore.java"
    },
    {
      "type": "add",
      "old_id": "0000000000000000000000000000000000000000",
      "old_mode": 0,
      "old_path": "/dev/null",
      "new_id": "9f523219ddd5d39b1e0de293b46cc93518ce4923",
      "new_mode": 33188,
      "new_path": "eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/offset/PushOffsetStore.java"
    },
    {
      "type": "modify",
      "old_id": "89a89e278ed148ea2e9d71a6ef307ed45687f3f6",
      "old_mode": 33188,
      "old_path": "eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/offset/RocksDBOffsetStore.java",
      "new_id": "b5b0e68071ae6eb1b5320889924abf04c18a748d",
      "new_mode": 33188,
      "new_path": "eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/offset/RocksDBOffsetStore.java"
    },
    {
      "type": "modify",
      "old_id": "e441a88e8a7958e2f9dc5ec984a999b3ed8ff00a",
      "old_mode": 33188,
      "old_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/admin/UniAdminServiceTest.java",
      "new_id": "20c6d8128371b846304eb3be852562adac7207e7",
      "new_mode": 33188,
      "new_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/admin/UniAdminServiceTest.java"
    },
    {
      "type": "add",
      "old_id": "0000000000000000000000000000000000000000",
      "old_mode": 0,
      "old_path": "/dev/null",
      "new_id": "30a9683de411bdb0de95bc20425fc8dcee988dbd",
      "new_mode": 33188,
      "new_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/boot/PullOffsetAlignmentTest.java"
    },
    {
      "type": "modify",
      "old_id": "8eaa53b78bcccbcea7f1b9725ab8b7e8460e942c",
      "old_mode": 33188,
      "old_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/http/LegacyHttpServerIntegrationTest.java",
      "new_id": "a4e64274d8ffaa55254ba9d6864f7ffc60cc4fe7",
      "new_mode": 33188,
      "new_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/http/LegacyHttpServerIntegrationTest.java"
    },
    {
      "type": "modify",
      "old_id": "bf3090af4696534d2098cada1766cf0d2474fb10",
      "old_mode": 33188,
      "old_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/ingress/UniIngressServiceTest.java",
      "new_id": "3b1a34ca4686787195f0144f8625514234bc4ef6",
      "new_mode": 33188,
      "new_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/ingress/UniIngressServiceTest.java"
    },
    {
      "type": "modify",
      "old_id": "476ff26ca043b59111e00223e5a3601ca1f9b444",
      "old_mode": 33188,
      "old_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/it/AckTimeoutRedeliveryIntegrationTest.java",
      "new_id": "812d6087c1092ea993bacb6e2226ff6e36a525a5",
      "new_mode": 33188,
      "new_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/it/AckTimeoutRedeliveryIntegrationTest.java"
    },
    {
      "type": "modify",
      "old_id": "c6ff182f83ce97b937337b98a65df15523bcc579",
      "old_mode": 33188,
      "old_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/it/BatchPublishIntegrationTest.java",
      "new_id": "38fa380fcc27a7698425d01bd65777886775d701",
      "new_mode": 33188,
      "new_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/it/BatchPublishIntegrationTest.java"
    },
    {
      "type": "modify",
      "old_id": "c64ba3e3b2c17bfbcb62e6ae6c13d17594b34633",
      "old_mode": 33188,
      "old_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/it/DlqIntegrationTest.java",
      "new_id": "63230d3cd2bdd983b9cd4c6ee0ecd7d614936929",
      "new_mode": 33188,
      "new_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/it/DlqIntegrationTest.java"
    },
    {
      "type": "modify",
      "old_id": "4cada3a2afe999814bd134dc6bd8a14fa1175694",
      "old_mode": 33188,
      "old_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/it/RealBrokerIntegrationTest.java",
      "new_id": "25fbe6c4f793fbb45cab0596935721b9e1648ea1",
      "new_mode": 33188,
      "new_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/it/RealBrokerIntegrationTest.java"
    },
    {
      "type": "modify",
      "old_id": "e91621e0e0a1020013dafee79a941f2e885be830",
      "old_mode": 33188,
      "old_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/it/RequestReplyHttpIntegrationTest.java",
      "new_id": "63549dc5c9900b01fdcc865c5c92fae8861cad8d",
      "new_mode": 33188,
      "new_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/it/RequestReplyHttpIntegrationTest.java"
    },
    {
      "type": "modify",
      "old_id": "7ad8391efe180f77aecfd68accc20e9312a2c339",
      "old_mode": 33188,
      "old_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/it/WebSocketPushIntegrationTest.java",
      "new_id": "825f8ab55cca9f42c8b0a3b346ce13737158b3e6",
      "new_mode": 33188,
      "new_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/it/WebSocketPushIntegrationTest.java"
    },
    {
      "type": "modify",
      "old_id": "520390a10aa792fe555e9d8322b47412ec3eb5ef",
      "old_mode": 33188,
      "old_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/offset/OffsetStoreTest.java",
      "new_id": "3c9ddaf3f5b7b8c96ac75c7aceca290a866714e3",
      "new_mode": 33188,
      "new_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/offset/OffsetStoreTest.java"
    },
    {
      "type": "add",
      "old_id": "0000000000000000000000000000000000000000",
      "old_mode": 0,
      "old_path": "/dev/null",
      "new_id": "9679fb2174bec3ff1da86ffb62b6990dfb4a5f07",
      "new_mode": 33188,
      "new_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/offset/PushOffsetStoreTest.java"
    },
    {
      "type": "modify",
      "old_id": "d5605a95ad5aa1c5be75c8bb25ad69d8d40c0ad7",
      "old_mode": 33188,
      "old_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/transport/http/LegacyHttpBridgeTest.java",
      "new_id": "769c26cb8c8e6ba1bbc22d7e5dcfc12b9b2da8d9",
      "new_mode": 33188,
      "new_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/transport/http/LegacyHttpBridgeTest.java"
    },
    {
      "type": "modify",
      "old_id": "880a25af2725facbf61b7349c95ce4781a8d015b",
      "old_mode": 33188,
      "old_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/transport/tcp/UniTcpServerTest.java",
      "new_id": "f9069179532ebf40717e2a61fbde1b4b962f7f7d",
      "new_mode": 33188,
      "new_path": "eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/transport/tcp/UniTcpServerTest.java"
    },
    {
      "type": "modify",
      "old_id": "0844fc534d15b30afdfe3cd64742d4a00d9fc41d",
      "old_mode": 33188,
      "old_path": "eventmesh-storage-plugin/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/storage/MeshStoragePlugin.java",
      "new_id": "8dc25d79bdea7b97119ae42bef6dc27aae808ad7",
      "new_mode": 33188,
      "new_path": "eventmesh-storage-plugin/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/storage/MeshStoragePlugin.java"
    },
    {
      "type": "add",
      "old_id": "0000000000000000000000000000000000000000",
      "old_mode": 0,
      "old_path": "/dev/null",
      "new_id": "9eb5ebde732d594910d8dfb2457af9828e9da75d",
      "new_mode": 33188,
      "new_path": "eventmesh-storage-plugin/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/storage/OffsetExtensions.java"
    },
    {
      "type": "modify",
      "old_id": "f7d6853a12d369568c897dfbe73da5f02b366fa6",
      "old_mode": 33188,
      "old_path": "eventmesh-storage-plugin/eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage/kafka/storage/KafkaMeshStoragePlugin.java",
      "new_id": "6cc31cd1b96fc74df8021fde1850ece2934d3ac3",
      "new_mode": 33188,
      "new_path": "eventmesh-storage-plugin/eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage/kafka/storage/KafkaMeshStoragePlugin.java"
    },
    {
      "type": "modify",
      "old_id": "62edfb746ea9cf74c7e3109e2bd099169454fe79",
      "old_mode": 33188,
      "old_path": "eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/storage/RocketMQRemotingStoragePlugin.java",
      "new_id": "2327fd073c2c99a42594e7f2b9aa5d73cd011b8a",
      "new_mode": 33188,
      "new_path": "eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/storage/RocketMQRemotingStoragePlugin.java"
    },
    {
      "type": "modify",
      "old_id": "4fb9fa24452abf1db14df42bff482259a854d4a4",
      "old_mode": 33188,
      "old_path": "eventmesh-storage-plugin/eventmesh-storage-rocketmq5/src/main/java/org/apache/eventmesh/storage/rocketmq5/storage/RocketMQ5RemotingStoragePlugin.java",
      "new_id": "c5982adc256308007f4dae7d0b3676f8a87af91d",
      "new_mode": 33188,
      "new_path": "eventmesh-storage-plugin/eventmesh-storage-rocketmq5/src/main/java/org/apache/eventmesh/storage/rocketmq5/storage/RocketMQ5RemotingStoragePlugin.java"
    }
  ]
}