diff --git a/apps/emqx_durable_storage/test/emqx_ds_test_helpers.erl b/apps/emqx_durable_storage/test/emqx_ds_test_helpers.erl
index fe903fad2..08c08e0c5 100644
--- a/apps/emqx_durable_storage/test/emqx_ds_test_helpers.erl
+++ b/apps/emqx_durable_storage/test/emqx_ds_test_helpers.erl
@@ -122,6 +122,7 @@ topic_messages(TestCase, ClientId, N) ->
     fun() ->
         NBin = integer_to_binary(N),
         Msg = #message{
+            id = <<N:128>>,
             from = ClientId,
             topic = client_topic(TestCase, ClientId),
             timestamp = N * 100,