From 69a896df0018eedc2e1631c58d7c1255aa21079b Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Fri, 18 Nov 2016 22:25:51 -0500 Subject: [PATCH] Fix Kafka-0.10.1.0 compatibility https://build.spring.io/browse/INTSAMPLES-NIGHTLY-JOB1-1923/ --- .../springframework/integration/samples/kafka/Application.java | 2 +- .../integration/samples/dsl/kafka/Application.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/basic/kafka/src/main/java/org/springframework/integration/samples/kafka/Application.java b/basic/kafka/src/main/java/org/springframework/integration/samples/kafka/Application.java index a41ea0ce..8af9f386 100644 --- a/basic/kafka/src/main/java/org/springframework/integration/samples/kafka/Application.java +++ b/basic/kafka/src/main/java/org/springframework/integration/samples/kafka/Application.java @@ -53,7 +53,7 @@ import org.springframework.messaging.PollableChannel; import org.springframework.messaging.support.GenericMessage; import kafka.admin.AdminUtils; -import kafka.common.TopicExistsException; +import org.apache.kafka.common.errors.TopicExistsException; import kafka.utils.ZKStringSerializer$; import kafka.utils.ZkUtils; diff --git a/dsl/kafka-dsl/src/main/java/org/springframework/integration/samples/dsl/kafka/Application.java b/dsl/kafka-dsl/src/main/java/org/springframework/integration/samples/dsl/kafka/Application.java index 01453306..96a91b76 100644 --- a/dsl/kafka-dsl/src/main/java/org/springframework/integration/samples/dsl/kafka/Application.java +++ b/dsl/kafka-dsl/src/main/java/org/springframework/integration/samples/dsl/kafka/Application.java @@ -46,7 +46,7 @@ import org.springframework.kafka.core.ProducerFactory; import org.springframework.messaging.Message; import kafka.admin.AdminUtils; -import kafka.common.TopicExistsException; +import org.apache.kafka.common.errors.TopicExistsException; import kafka.utils.ZKStringSerializer$; import kafka.utils.ZkUtils;