From 3b4d28eec36e880a476de8a6217f34a2575da8e3 Mon Sep 17 00:00:00 2001
From: mcy <rewerma@163.com>
Date: Sun, 28 Oct 2018 21:30:54 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E8=AF=95=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../canal/client/running/kafka/KafkaClientRunningTest.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/client/src/test/java/com/alibaba/otter/canal/client/running/kafka/KafkaClientRunningTest.java b/client/src/test/java/com/alibaba/otter/canal/client/running/kafka/KafkaClientRunningTest.java
index fcdc0bf6..1b2afec4 100644
--- a/client/src/test/java/com/alibaba/otter/canal/client/running/kafka/KafkaClientRunningTest.java
+++ b/client/src/test/java/com/alibaba/otter/canal/client/running/kafka/KafkaClientRunningTest.java
@@ -40,7 +40,7 @@ public class KafkaClientRunningTest extends AbstractKafkaTest {
                 connector.subscribe();
                 while (running) {
                     try {
-                        List<Message> messages = connector.getWithoutAck(3L, TimeUnit.SECONDS);
+                        List<Message> messages = connector.getList(3L, TimeUnit.SECONDS);
                         if (messages != null) {
                             System.out.println(messages);
                         }