Fix Tests for Latest Spring Milestone

NestedException messages no longer traverse causes.

Author: garyrussell

spring-kafka/src/test/java/org/springframework/kafka/core/DefaultKafkaProducerFactoryTests.java

@@ -107,7 +107,7 @@ protected Producer createRawProducer(Map configs) {
 						return null;
 					});
 				})
-				.withMessageContaining("Invalid transition");
+				.withStackTraceContaining("Invalid transition");
 
 		assertThat(queue).hasSize(0);
 

spring-kafka/src/test/java/org/springframework/kafka/listener/ErrorHandlingDeserializerTests.java

@@ -131,7 +131,7 @@ public String deserialize(String topic, Headers headers, byte[] data) {
 		ehd.deserialize("foo", headers, new byte[1]);
 		DeserializationException dex = ListenerUtils.byteArrayToDeserializationException(null,
 				headers.lastHeader(SerializationUtils.VALUE_DESERIALIZER_EXCEPTION_HEADER).value());
-		assertThat(dex.getMessage())
+		assertThat(dex.getCause().getMessage())
 				.contains("Could not serialize")
 				.contains("original exception message");
 	}

spring-kafka/src/test/java/org/springframework/kafka/listener/MissingGroupIdTests.java

@@ -60,7 +60,7 @@ public void testContextFailsWithKafkaListener() {
 				new AnnotationConfigApplicationContext(Config1.class);
 		})
 			.withCauseInstanceOf(IllegalStateException.class)
-			.withMessageContaining("No group.id found in consumer config");
+			.withStackTraceContaining("No group.id found in consumer config");
 	}
 
 	@Test
@@ -69,7 +69,7 @@ public void testContextFailsWithSubscribedContainer() {
 				new AnnotationConfigApplicationContext(Config2.class);
 		})
 			.withCauseInstanceOf(IllegalStateException.class)
-			.withMessageContaining("No group.id found in consumer config");
+			.withStackTraceContaining("No group.id found in consumer config");
 	}
 
 	@Test

spring-kafka/src/test/java/org/springframework/kafka/listener/TransactionalContainerTests.java

@@ -752,8 +752,10 @@ public void accept(ConsumerRecord<?, ?> record, Consumer<?, ?> consumer, Excepti
 		assertThat(new String(headers.get(KafkaHeaders.DLT_EXCEPTION_CAUSE_FQCN, byte[].class)))
 				.isEqualTo("java.lang.RuntimeException");
 		assertThat(headers.get(KafkaHeaders.DLT_EXCEPTION_MESSAGE, byte[].class))
-				.contains("fail for max failures".getBytes());
+				.contains("Listener failed".getBytes());
 		assertThat(headers.get(KafkaHeaders.DLT_EXCEPTION_STACKTRACE)).isNotNull();
+		assertThat(headers.get(KafkaHeaders.DLT_EXCEPTION_STACKTRACE, byte[].class))
+				.contains("fail for max failures".getBytes());
 		assertThat(headers.get(KafkaHeaders.DLT_ORIGINAL_OFFSET, byte[].class)[3]).isEqualTo((byte) 0);
 		assertThat(headers.get(KafkaHeaders.DLT_ORIGINAL_PARTITION, byte[].class)[3]).isEqualTo((byte) 0);
 		assertThat(headers.get(KafkaHeaders.DLT_ORIGINAL_TIMESTAMP, byte[].class)).isNotNull();

spring-kafka/src/test/java/org/springframework/kafka/listener/adapter/MessagingMessageListenerAdapterTests.java

@@ -77,7 +77,7 @@ void testMissingAck() throws NoSuchMethodException, SecurityException {
 		assertThatExceptionOfType(ListenerExecutionFailedException.class).isThrownBy(() -> adapter.onMessage(
 						new ConsumerRecord<>("foo", 0, 0L, null, "foo"), null, null))
 				.withCauseExactlyInstanceOf(IllegalStateException.class)
-				.withMessageContaining("MANUAL");
+				.withStackTraceContaining("MANUAL");
 	}
 
 	public void test(Acknowledgment ack) {