|
27 | 27 |
|
28 | 28 | import org.apache.commons.logging.Log;
|
29 | 29 | import org.apache.commons.logging.LogFactory;
|
30 |
| -import org.apache.kafka.clients.consumer.ConsumerConfig; |
31 | 30 | import org.apache.kafka.clients.consumer.ConsumerRebalanceListener;
|
32 | 31 | import org.apache.kafka.clients.producer.ProducerConfig;
|
33 | 32 | import org.apache.kafka.common.TopicPartition;
|
|
53 | 52 | import org.springframework.integration.kafka.outbound.KafkaProducerMessageHandler;
|
54 | 53 | import org.springframework.integration.kafka.support.KafkaIntegrationHeaders;
|
55 | 54 | import org.springframework.integration.support.MessageBuilder;
|
56 |
| -import org.springframework.integration.test.condition.LogLevels; |
57 | 55 | import org.springframework.integration.test.util.TestUtils;
|
58 | 56 | import org.springframework.kafka.annotation.EnableKafka;
|
59 | 57 | import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory;
|
|
99 | 97 | */
|
100 | 98 | @SpringJUnitConfig
|
101 | 99 | @DirtiesContext
|
102 |
| -@LogLevels(level = "debug", categories = "org.apache.kafka.clients.consumer") |
103 | 100 | public class KafkaDslTests {
|
104 | 101 |
|
105 | 102 | private static final Log log = LogFactory.getLog(KafkaDslTests.class);
|
@@ -284,7 +281,6 @@ public static class ContextConfiguration {
|
284 | 281 | @Bean
|
285 | 282 | public ConsumerFactory<Integer, String> consumerFactory() {
|
286 | 283 | Map<String, Object> props = KafkaTestUtils.consumerProps(this.embeddedKafkaBrokers, "dsl-group", "false");
|
287 |
| - props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest"); |
288 | 284 | return new DefaultKafkaConsumerFactory<>(props);
|
289 | 285 | }
|
290 | 286 |
|
|
0 commit comments