File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed
pulsar-io/http/src/test/java/org/apache/pulsar/io/http Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change 2121import static com .github .tomakehurst .wiremock .client .WireMock .aResponse ;
2222import static com .github .tomakehurst .wiremock .client .WireMock .configureFor ;
2323import static com .github .tomakehurst .wiremock .client .WireMock .equalTo ;
24+ import static com .github .tomakehurst .wiremock .client .WireMock .equalToJson ;
2425import static com .github .tomakehurst .wiremock .client .WireMock .post ;
2526import static com .github .tomakehurst .wiremock .client .WireMock .postRequestedFor ;
2627import static com .github .tomakehurst .wiremock .client .WireMock .stubFor ;
@@ -424,7 +425,7 @@ public Optional<Long> getIndex() {
424425 httpSink .write (record );
425426
426427 verify (postRequestedFor (urlEqualTo ("/" ))
427- .withRequestBody (equalTo (responseBody ))
428+ .withRequestBody (equalToJson (responseBody ))
428429 .withHeader ("Content-Type" , equalTo ("application/json" ))
429430 .withHeader ("header-name" , equalTo ("header-value" ))
430431 .withHeader ("PulsarTopic" , equalTo ("test-topic" ))
You can’t perform that action at this time.
0 commit comments