From 2378f3f95414780f941698e938906024c50a7991 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Thu, 19 Dec 2024 10:26:33 -0500 Subject: [PATCH] Don't use `earliest` offset reset in the `KafkaDslTests` --- .../springframework/integration/kafka/dsl/KafkaDslTests.java | 4 ---- 1 file changed, 4 deletions(-) diff --git a/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java b/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java index 2116847504..645b7bc6e3 100644 --- a/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java +++ b/spring-integration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java @@ -27,7 +27,6 @@ import java.util.stream.Stream; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; -import org.apache.kafka.clients.consumer.ConsumerConfig; import org.apache.kafka.clients.consumer.ConsumerRebalanceListener; import org.apache.kafka.clients.producer.ProducerConfig; import org.apache.kafka.common.TopicPartition; @@ -53,7 +52,6 @@ import org.springframework.integration.kafka.inbound.KafkaMessageSource; import org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler; import org.springframework.integration.kafka.support.KafkaIntegrationHeaders; import org.springframework.integration.support.MessageBuilder; -import org.springframework.integration.test.condition.LogLevels; import org.springframework.integration.test.util.TestUtils; import org.springframework.kafka.annotation.EnableKafka; import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory; @@ -99,7 +97,6 @@ import static org.assertj.core.api.Assertions.assertThat; */ @SpringJUnitConfig @DirtiesContext -@LogLevels(level = "debug", categories = "org.apache.kafka.clients.consumer") public class KafkaDslTests { private static final Log log = LogFactory.getLog(KafkaDslTests.class); @@ -284,7 +281,6 @@ public class KafkaDslTests { @Bean public ConsumerFactory consumerFactory() { Map props = KafkaTestUtils.consumerProps(this.embeddedKafkaBrokers, "dsl-group", "false"); - props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest"); return new DefaultKafkaConsumerFactory<>(props); }