mirror of
https://github.com/alibaba/canal.git
synced 2026-11-04 00:30:15 +08:00
增加缺失的import语句,修改文字错误的代码
@@ -44,6 +44,8 @@ maven3.0.5以上版本舍弃了create,使用generate生成项目
|
||||
import java.net.InetSocketAddress;
|
||||
import java.util.List;
|
||||
|
||||
import com.alibaba.otter.canal.client.CanalConnectors;
|
||||
import com.alibaba.otter.canal.client.CanalConnector;
|
||||
import com.alibaba.otter.canal.common.utils.AddressUtils;
|
||||
import com.alibaba.otter.canal.protocol.Message;
|
||||
import com.alibaba.otter.canal.protocol.CanalEntry.Column;
|
||||
@@ -128,7 +130,7 @@ public class SimpleCanalClientExample {
|
||||
}
|
||||
}
|
||||
|
||||
private static void printColumn(List<Column> columns) {
|
||||
private static void printColumn(List<Column> columns) {
|
||||
for (Column column : columns) {
|
||||
System.out.println(column.getName() + " : " + column.getValue() + " update=" + column.getUpdated());
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user