From 88250f92bd80ca2dcbb843231c3df4fb11675047 Mon Sep 17 00:00:00 2001 From: Scott Frederick Date: Thu, 5 May 2022 17:17:23 -0500 Subject: [PATCH] Adapt to changes in Spring Kafka snapshots See gh-30645 --- .../kafka/KafkaAutoConfigurationIntegrationTests.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/spring-boot-project/spring-boot-autoconfigure/src/test/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfigurationIntegrationTests.java b/spring-boot-project/spring-boot-autoconfigure/src/test/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfigurationIntegrationTests.java index 7e14da6f48..c949dea3be 100644 --- a/spring-boot-project/spring-boot-autoconfigure/src/test/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfigurationIntegrationTests.java +++ b/spring-boot-project/spring-boot-autoconfigure/src/test/java/org/springframework/boot/autoconfigure/kafka/KafkaAutoConfigurationIntegrationTests.java @@ -181,7 +181,7 @@ class KafkaAutoConfigurationIntegrationTests { private volatile String key; @KafkaListener(topics = TEST_TOPIC) - void listen(String foo, @Header(KafkaHeaders.RECEIVED_MESSAGE_KEY) String key) { + void listen(String foo, @Header(KafkaHeaders.RECEIVED_KEY) String key) { this.received = foo; this.key = key; this.latch.countDown(); @@ -200,7 +200,7 @@ class KafkaAutoConfigurationIntegrationTests { private volatile String key; @KafkaListener(topics = TEST_RETRY_TOPIC) - void listen(String foo, @Header(KafkaHeaders.RECEIVED_MESSAGE_KEY) String key, + void listen(String foo, @Header(KafkaHeaders.RECEIVED_KEY) String key, @Header(KafkaHeaders.RECEIVED_TOPIC) String topic) { this.received = foo; this.key = key;