Skip to content
Snippets Groups Projects

Upgrade Kafka Streams Benchmarks to Kafka Streams 3.1

Merged Sören Henning requested to merge upgrade-kstreams into upgrade-flink
1 file
+ 2
1
Compare changes
  • Side-by-side
  • Inline
@@ -45,8 +45,9 @@ public class HttpRecordSenderTest {
final ActivePowerRecord record = new ActivePowerRecord("my-id", 12345L, 12.34);
this.httpRecordSender.send(record);
final String expectedJson = "{\"identifier\":\"my-id\",\"timestamp\":12345,\"valueInW\":12.34}";
verify(exactly(1), postRequestedFor(urlEqualTo("/"))
.withRequestBody(equalTo(this.gson.toJson(record)))); // toJson
.withRequestBody(equalTo(expectedJson))); // toJson
}
}
Loading