From 7b80b3107fb0d1f91429fb56453a3191ef217a33 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Tue, 8 Apr 2025 07:03:47 +0200 Subject: [PATCH] Refactor: Test setzt eigenen Header-Prefix selbst --- src/test/java/de/juplo/kafka/ApplicationTests.java | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java index a4dc033..f26ee16 100644 --- 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 kafkaTemplate; @@ -164,8 +165,6 @@ public class ApplicationTests AdminClient adminClient; @Autowired TestRestTemplate restTemplate; - @Autowired - DeadLetterConsumer deadLetterConsumer; final long[] currentOffsets = new long[NUM_PARTITIONS]; -- 2.20.1