Don't use earliest offset reset in the KafkaDslTests

spring-projects · Dec 19, 2024 · 2378f3f · 2378f3f
1 parent 0781aad
commit 2378f3f
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/...egration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java b/...egration-kafka/src/test/java/org/springframework/integration/kafka/dsl/KafkaDslTests.java
@@ -27,7 +27,6 @@
 
 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.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 @@
  */
 @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 static class ContextConfiguration {
 		@Bean
 		public ConsumerFactory<Integer, String> consumerFactory() {
 			Map<String, Object> props = KafkaTestUtils.consumerProps(this.embeddedKafkaBrokers, "dsl-group", "false");
-			props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
 			return new DefaultKafkaConsumerFactory<>(props);
 		}