This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-4.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit f71ff1e485a796b7bfa1419b468e5ba96db5805e Author: Lucas Eby <[email protected]> AuthorDate: Tue Nov 11 09:26:33 2025 -0600 [fix][test] Fixed ResponseBody Check in Test Helper (#24872) (cherry picked from commit 246325416fcdcb382e025e9d498c9ac57d4a68b8) --- .../http/src/test/java/org/apache/pulsar/io/http/HttpSinkTest.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 c7c8aa92a2f..289c0ad26a2 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 @@ package org.apache.pulsar.io.http; 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; @@ -424,7 +425,7 @@ public class HttpSinkTest { 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"))
