Refactor: Test setzt eigenen Header-Prefix selbst

diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index fbd283800a56840380d0eb149711e6708917c4da..7549f0a15a8f87361fa5f0d977eafa0c7aafea67 100644 (file)
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -34,8 +34,7 @@ import java.util.concurrent.ExecutionException;
 import java.util.stream.Collectors;
 import java.util.stream.IntStream;
 
-import static de.juplo.kafka.ApplicationTests.NUM_PARTITIONS;
-import static de.juplo.kafka.ApplicationTests.TOPIC;
+import static de.juplo.kafka.ApplicationTests.*;
 import static org.assertj.core.api.Assertions.assertThat;
 
 
@@ -44,6 +43,7 @@ import static org.assertj.core.api.Assertions.assertThat;
   properties = {
     "juplo.bootstrap-server=${spring.embedded.kafka.brokers}",
     "juplo.consumer.topic=" + TOPIC,
+    "juplo.consumer.header-prefix=" + HEADER_PREFIX,
     "spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.ByteArraySerializer",
     "spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.ByteArraySerializer",
     "logging.level.de.juplo.kafka=TRACE",
@@ -105,9 +105,9 @@ public class ApplicationTests
 
     assertThat(response.getStatusCode())
       .isEqualTo(HttpStatusCode.valueOf(HttpStatus.OK.value()));
-    assertThat(response.getHeaders().getValuesAsList(DeadLetterConsumer.KEY))
+    assertThat(response.getHeaders().getValuesAsList(HEADER_PREFIX + DeadLetterConsumer.KEY))
       .containsExactly(key);
-    assertThat(response.getHeaders().getValuesAsList(DeadLetterConsumer.TIMESTAMP))
+    assertThat(response.getHeaders().getValuesAsList(HEADER_PREFIX + DeadLetterConsumer.TIMESTAMP))
       .containsExactly(Long.toString(recordMetadata.timestamp()));
     assertThat(response.getBody())
       .isEqualTo(value);
@@ -153,6 +153,7 @@ public class ApplicationTests
   static final String TOPIC = "ExampleConsumerTest_TEST";
   static final int NUM_PARTITIONS = 7;
   static final int[] PARTITIONS = IntStream.range(0, NUM_PARTITIONS).toArray();
+  static final String HEADER_PREFIX = "X-FOO--";
 
   @Autowired
   KafkaTemplate<byte[], byte[]> kafkaTemplate;
@@ -160,8 +161,6 @@ public class ApplicationTests
   AdminClient adminClient;
   @Autowired
   TestRestTemplate restTemplate;
-  @Autowired
-  DeadLetterConsumer deadLetterConsumer;
 
   final long[] currentOffsets = new long[NUM_PARTITIONS];