You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by lh...@apache.org on 2025/11/11 17:47:46 UTC
(pulsar) 01/04: [fix][test] Fixed ResponseBody Check in Test Helper (#24872)
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 <90...@users.noreply.github.com>
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"))