mirror of
https://github.com/alibaba/canal.git
synced 2026-11-04 00:30:15 +08:00
修改为 List<Entry>
@@ -91,7 +91,7 @@ public class SimpleCanalClientExample {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private static void printEntry(List<Entry> entrys) {
|
private static void printEntry(List<Entry> entrys) {
|
||||||
for (Entry entry : entrys) {
|
for (Entry entry : entrys) {
|
||||||
if (entry.getEntryType() == EntryType.TRANSACTIONBEGIN || entry.getEntryType() == EntryType.TRANSACTIONEND) {
|
if (entry.getEntryType() == EntryType.TRANSACTIONBEGIN || entry.getEntryType() == EntryType.TRANSACTIONEND) {
|
||||||
continue;
|
continue;
|
||||||
|
|||||||
Reference in New Issue
Block a user