diff --git a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/StreamingKafkaITCase.java b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/StreamingKafkaITCase.java index 5e641597277a9..00d050b8fb25d 100644 --- a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/StreamingKafkaITCase.java +++ b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/StreamingKafkaITCase.java @@ -163,10 +163,10 @@ public void testKafka() throws Exception { final List bees = filterMessages(messages, "bee"); final List 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); } } }