Spring/spring-integration-samples
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix Kafka-0.10.1.0 compatibility

Browse Source 
https://build.spring.io/browse/INTSAMPLES-NIGHTLY-JOB1-1923/
This commit is contained in:
Artem Bilan
2016-11-18 22:25:51 -05:00
parent 5f524dc534
commit 69a896df00
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
basic/kafka/src/main/java/org/springframework/integration/samples/kafka/Application.java
View File

@@ -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;

2
dsl/kafka-dsl/src/main/java/org/springframework/integration/samples/dsl/kafka/Application.java
View File

@@ -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;