From 81b9ae4a7ae4c85c6cd813dcb9c1a3fe0c611507 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Tue, 17 Mar 2020 13:30:36 -0400 Subject: [PATCH] Use core Kotlin DSL --- .../integration/kafka/dsl/kotlin/KafkaDslKotlinTests.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-integration-kafka/src/test/kotlin/org/springframework/integration/kafka/dsl/kotlin/KafkaDslKotlinTests.kt b/spring-integration-kafka/src/test/kotlin/org/springframework/integration/kafka/dsl/kotlin/KafkaDslKotlinTests.kt index f232047011..9aac684f24 100644 --- a/spring-integration-kafka/src/test/kotlin/org/springframework/integration/kafka/dsl/kotlin/KafkaDslKotlinTests.kt +++ b/spring-integration-kafka/src/test/kotlin/org/springframework/integration/kafka/dsl/kotlin/KafkaDslKotlinTests.kt @@ -37,7 +37,7 @@ import org.springframework.integration.MessageRejectedException import org.springframework.integration.channel.QueueChannel import org.springframework.integration.config.EnableIntegration import org.springframework.integration.dsl.Pollers -import org.springframework.integration.dsl.kotlin.integrationFlow +import org.springframework.integration.dsl.integrationFlow import org.springframework.integration.handler.advice.ErrorMessageSendingRecoverer import org.springframework.integration.kafka.dsl.Kafka import org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter