chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

kafka consumer 测试类修改

Browse Source
This commit is contained in:
rewerma
2018-06-13 15:40:49 +08:00
parent 4e41ebf746
commit 19f4c5ae1b
1 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
kafka-client/src/test/java/com/alibaba/otter/canal/kafka/client/running/KafkaClientRunningTest.java
View File

@@ -28,11 +28,11 @@ public class KafkaClientRunningTest extends AbstractKafkaTest {
final ExecutorService executor = Executors.newFixedThreadPool(1); final ExecutorService executor = Executors.newFixedThreadPool(1);
final KafkaCanalConnector connector = KafkaCanalConnectors.newKafkaConnector(servers, topic, partition, groupId); final KafkaCanalConnector connector = KafkaCanalConnectors.newKafkaConnector(servers, topic, partition, groupId);
connector.subscribe();
executor.submit(new Runnable() { executor.submit(new Runnable() {
@Override @Override
public void run() { public void run() {
connector.subscribe();
while (running) { while (running) {
try { try {
Message message = connector.getWithoutAck(3L, TimeUnit.SECONDS); Message message = connector.getWithoutAck(3L, TimeUnit.SECONDS);
@@ -53,8 +53,6 @@ public class KafkaClientRunningTest extends AbstractKafkaTest {
running = false; running = false;
executor.shutdown(); executor.shutdown();
logger.info("shutdown completed"); logger.info("shutdown completed");
sleep(10000);
} }
} }