Skip to content

Commit dcc0ac3

Browse files
jarad0628mnianqi
authored andcommitted
fix: oceanbase-mysql missing ddl and heartbeat
fix: batchRead with streaming (cherry picked from commit 2965d48)
1 parent db9f6c1 commit dcc0ac3

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

connectors/oceanbase-mysql-connector/src/main/java/io/tapdata/oceanbase/cdc/OceanbaseReader.java

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -77,13 +77,19 @@ public void start(BooleanSupplier isAlive) throws Throwable {
7777
@Override
7878
public void notify(LogMessage message) {
7979
try {
80+
String op = message.getOpt().name();
8081
if (!tableList.contains(message.getTableName())) {
81-
return;
82+
switch (op) {
83+
case "INSERT":
84+
case "UPDATE":
85+
case "DELETE":
86+
return;
87+
}
8288
}
8389
Map<String, Object> after = DataMap.create();
8490
Map<String, Object> before = DataMap.create();
8591
analyzeMessage(message, after, before);
86-
switch (message.getOpt().name()) {
92+
switch (op) {
8793
case "INSERT":
8894
eventList.get().add(new TapInsertRecordEvent().init().table(message.getTableName()).after(after).referenceTime(Long.parseLong(message.getTimestamp()) * 1000));
8995
break;

0 commit comments

Comments
 (0)