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 a4dc033..f26ee16 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",
@@ -107,11 +107,11 @@ public class ApplicationTests
       .isEqualTo(HttpStatusCode.valueOf(HttpStatus.OK.value()));
     assertThat(response.getHeaders())
       .containsEntry(
-        deadLetterConsumer.prefixed(DeadLetterConsumer.KEY),
+        HEADER_PREFIX + DeadLetterConsumer.KEY,
         List.of(key));
     assertThat(response.getHeaders())
       .containsEntry(
-        deadLetterConsumer.prefixed(DeadLetterConsumer.TIMESTAMP),
+        HEADER_PREFIX + DeadLetterConsumer.TIMESTAMP,
         List.of(Long.toString(recordMetadata.timestamp())));
     assertThat(response.getBody())
       .isEqualTo(value);
@@ -157,6 +157,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;
@@ -164,8 +165,6 @@ public class ApplicationTests
   AdminClient adminClient;
   @Autowired
   TestRestTemplate restTemplate;
-  @Autowired
-  DeadLetterConsumer deadLetterConsumer;
 
   final long[] currentOffsets = new long[NUM_PARTITIONS];