diff --git a/pulsar-io/http/src/test/java/org/apache/pulsar/io/http/HttpSinkTest.java b/pulsar-io/http/src/test/java/org/apache/pulsar/io/http/HttpSinkTest.java
index e1e8a21834566..6ad8f45e73155 100644
--- a/pulsar-io/http/src/test/java/org/apache/pulsar/io/http/HttpSinkTest.java
+++ b/pulsar-io/http/src/test/java/org/apache/pulsar/io/http/HttpSinkTest.java
@@ -21,6 +21,7 @@
 import static com.github.tomakehurst.wiremock.client.WireMock.aResponse;
 import static com.github.tomakehurst.wiremock.client.WireMock.configureFor;
 import static com.github.tomakehurst.wiremock.client.WireMock.equalTo;
+import static com.github.tomakehurst.wiremock.client.WireMock.equalToJson;
 import static com.github.tomakehurst.wiremock.client.WireMock.post;
 import static com.github.tomakehurst.wiremock.client.WireMock.postRequestedFor;
 import static com.github.tomakehurst.wiremock.client.WireMock.stubFor;
@@ -429,7 +430,7 @@ public Optional<Long> getIndex() {
         httpSink.write(record);
 
         verify(postRequestedFor(urlEqualTo("/"))
-            .withRequestBody(equalTo(responseBody))
+            .withRequestBody(equalToJson(responseBody))
             .withHeader("Content-Type", equalTo("application/json"))
             .withHeader("header-name", equalTo("header-value"))
             .withHeader("PulsarTopic", equalTo("test-topic"))