From e23a19cd8555b5ccd00e9f7cf317a8541bf5b72a Mon Sep 17 00:00:00 2001 From: rewerma Date: Wed, 13 Jun 2018 18:29:15 +0800 Subject: [PATCH] =?UTF-8?q?=E6=95=B4=E7=90=86=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../otter/canal/kafka/client/running/AbstractKafkaTest.java | 2 +- kafka/src/main/resources/kafka.yml | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/kafka-client/src/test/java/com/alibaba/otter/canal/kafka/client/running/AbstractKafkaTest.java b/kafka-client/src/test/java/com/alibaba/otter/canal/kafka/client/running/AbstractKafkaTest.java index f1e52be4..4d621e10 100644 --- a/kafka-client/src/test/java/com/alibaba/otter/canal/kafka/client/running/AbstractKafkaTest.java +++ b/kafka-client/src/test/java/com/alibaba/otter/canal/kafka/client/running/AbstractKafkaTest.java @@ -13,7 +13,7 @@ public abstract class AbstractKafkaTest { public static String topic = "example"; public static Integer partition = null; public static String groupId = "g1"; - public static String servers = "slave1.test.apitops.com:6667,slave2.test.apitops.com:6667,slave3.test.apitops.com:6667"; + public static String servers = "slave1:6667,slave2:6667,slave3:6667"; public void sleep(long time) { try { diff --git a/kafka/src/main/resources/kafka.yml b/kafka/src/main/resources/kafka.yml index b46f123c..ab214319 100644 --- a/kafka/src/main/resources/kafka.yml +++ b/kafka/src/main/resources/kafka.yml @@ -1,10 +1,10 @@ -servers: slave1.test.apitops.com:6667,slave2.test.apitops.com:6667,slave3.test.apitops.com:6667 +servers: slave1:6667,slave2:6667,slave3:6667 retries: 0 batchSize: 16384 lingerMs: 1 bufferMemory: 33554432 # canal的批次大小，单位 k -canalBatchSize: 5 +canalBatchSize: 50 canalDestinations: - canalDestination: example