diff --git a/client-launcher/src/main/java/com/alibaba/otter/canal/client/adapter/loader/CanalAdapterKafkaWorker.java b/client-launcher/src/main/java/com/alibaba/otter/canal/client/adapter/loader/CanalAdapterKafkaWorker.java
index 5cf86611..4a7bd7a3 100644
--- a/client-launcher/src/main/java/com/alibaba/otter/canal/client/adapter/loader/CanalAdapterKafkaWorker.java
+++ b/client-launcher/src/main/java/com/alibaba/otter/canal/client/adapter/loader/CanalAdapterKafkaWorker.java
@@ -33,7 +33,7 @@ public class CanalAdapterKafkaWorker extends AbstractCanalAdapterWorker {
this.topic = topic;
this.canalDestination = topic;
connector = KafkaCanalConnectors.newKafkaConnector(zkServers, bootstrapServers, topic, null, groupId);
- // connector.setSessionTimeout(5L, TimeUnit.MINUTES);
+ connector.setSessionTimeout(5L, TimeUnit.MINUTES);
// super.initSwitcher(topic);
}
diff --git a/client/pom.xml b/client/pom.xml
index 2e48f9c5..02b0f66a 100644
--- a/client/pom.xml
+++ b/client/pom.xml
@@ -15,7 +15,93 @@
com.alibaba.otter
canal.protocol
${project.version}
+ true
+
+
+ com.google.protobuf
+ protobuf-java
+
+
+
+
+ io.netty
+ netty-all
+
+
+
+ org.apache.zookeeper
+ zookeeper
+
+
+ com.101tec
+ zkclient
+
+
+
+ commons-io
+ commons-io
+
+
+ commons-lang
+ commons-lang
+
+
+ commons-codec
+ commons-codec
+
+
+ com.alibaba
+ fastjson
+
+
+ com.google.guava
+ guava
+
+
+
+ ch.qos.logback
+ logback-core
+
+
+ ch.qos.logback
+ logback-classic
+
+
+ org.slf4j
+ jcl-over-slf4j
+
+
+ org.slf4j
+ slf4j-api
+
+
+ org.springframework
+ spring-core
+
+
+ org.springframework
+ spring-aop
+
+
+ org.springframework
+ spring-context
+
+
+ org.springframework
+ spring-jdbc
+
+
+ org.springframework
+ spring-orm
+
+
+ org.springframework
+ spring-test
+ ${spring_version}
+ test
+
+
org.apache.kafka
@@ -28,9 +114,76 @@
junit
junit
+ test
-
+
+
+
+
+ org.apache.maven.plugins
+ maven-shade-plugin
+ 2.4.1
+
+ false
+
+
+ org.apache.zookeeper:zookeeper
+ com.101tec:zkclient
+ commons-io:commons-io
+ commons-lang:commons-lang
+ commons-codec:commons-codec
+ com.alibaba:fastjson
+ ch.qos.logback:logback-core
+ ch.qos.logback:logback-classic
+ org.slf4j:jcl-over-slf4j
+ org.slf4j:slf4j-api
+ org.springframework:*
+ org.jboss.netty:netty
+ commons-logging:commons-logging
+ aopalliance:aopalliance
+ com.google.protobuf:protobuf-java
+ io.netty:*
+ junit:junit
+
+
+
+
+
+ package
+
+ shade
+
+
+
+
+ com.google.guava
+ com.alibaba.google.guava
+
+
+ org.joda
+ com.alibaba.google.joda
+
+
+ com.google.common
+ com.alibaba.google.common
+
+
+ com.google.thirdparty
+ com.alibaba.google.thirdparty
+
+
+
+
+
+
+
+
+
+
+
+
dev
@@ -98,7 +251,7 @@
${project.build.directory}/apidocs
true
scm:git:git@github.com:alibaba/canal.git
- gh-pages
+ gh-pages