ableegoldman commented on code in PR #12971:
URL: https://github.com/apache/kafka/pull/12971#discussion_r1044152824
##########
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest.java:
##########
@@ -196,19 +202,16 @@ public void
shouldThrowIllegalArgumentExceptionWhenCustomPartionerReturnsMultipl
for (final KafkaStreams stream: kafkaStreamsList) {
stream.setUncaughtExceptionHandler(e -> {
- assertEquals("The partitions returned by
StreamPartitioner#partitions method when used for FK join should be a singleton
set", e.getCause().getMessage());
+ Assertions.assertEquals("The partitions returned by
StreamPartitioner#partitions method when used for FK join should be a singleton
set", e.getCause().getMessage());
Review Comment:
We've been moving to `assertThat` instead of `assertEquals` and co:
```suggestion
assertThat(e.getCause().getMessage(), equalTo("The
partitions returned by StreamPartitioner#partitions method when used for FK
join should be a singleton set"));
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
