canal 支持多线程消费吗？

我目前的程序是单线程消费，日志来不及消费，有很大的延后，可以支持多线程消费吗？目前的Java代码如下：

while(true) { CanalConnector connector = CanalConnectors.newSingleConnector(new InetSocketAddress("127.0.0.1", 11111), "example", "", ""); int batchSize = 100; long batchId = 0; try { connector.connect(); connector.subscribe(); while (true) { try { Message message = connector.getWithoutAck(batchSize); batchId = message.getId(); int size = message.getEntries().size(); if (batchId == -1 || size == 0) { try { Thread.sleep(1000); } catch (Exception e) {} } else { printEntry(message.getEntries()); }

                connector.ack(batchId);
        	} catch(Exception ex) {
        		app.logger.error("main", ex);
        		connector.rollback(batchId);
        	}
        }
    } catch(Exception ex) {
    	app.logger.error("main", ex);
    } finally {
    	try {
    		connector.disconnect();
    	} catch(Exception ex) {}
    }

原提问者GitHub用户hezhiqiang