[FLINK-17260] Embellish assert output of StreamingKafkaITCase to help…

… debugging
is · Jun 8, 2020 · 50b6d9d · 50b6d9d
1 parent 0e8a53b
commit 50b6d9d
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...ts-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/StreamingKafkaITCase.java b/...ts-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/StreamingKafkaITCase.java
@@ -163,10 +163,10 @@ public void testKafka() throws Exception {
  final List<String> bees = filterMessages(messages, "bee");
  final List<String> giraffes = filterMessages(messages, "giraffe");
 
- Assert.assertEquals(Arrays.asList("elephant,27,64213"), elephants);
- Assert.assertEquals(Arrays.asList("squirrel,52,66413"), squirrels);
- Assert.assertEquals(Arrays.asList("bee,18,65647"), bees);
- Assert.assertEquals(Arrays.asList("giraffe,9,65555"), giraffes);
+ Assert.assertEquals(String.format("Messages from Kafka %s: %s", kafkaVersion, messages), Arrays.asList("elephant,27,64213"), elephants);
+ Assert.assertEquals(String.format("Messages from Kafka %s: %s", kafkaVersion, messages), Arrays.asList("squirrel,52,66413"), squirrels);
+ Assert.assertEquals(String.format("Messages from Kafka %s: %s", kafkaVersion, messages), Arrays.asList("bee,18,65647"), bees);
+ Assert.assertEquals(String.format("Messages from Kafka %s: %s", kafkaVersion, messages), Arrays.asList("giraffe,9,65555"), giraffes);
  }
  }
  }