This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-4.1 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit cb0998b37109b30181bcb9fe2746f80585a05a23 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 e1e8a218345..6ad8f45e731 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; @@ -429,7 +430,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"))
