alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-2913 Use new configurable MariaDB capabilities API

Browse Source
This commit is contained in:
Chris Cranford 2023-10-24 18:11:50 -04:00 committed by Jiri Pechanec
parent 66d788c875
commit dcce6f61f5
2 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java
View File

@ -212,6 +212,10 @@ public MySqlStreamingChangeEventSource(MySqlConnectorConfig connectorConfig, MyS
client.setSslSocketFactory(sslSocketFactory);
}
}
if (connection.isMariaDb()) {
// This makes sure BEGIN events are emitted via QUERY events rather than GTIDs.
client.setMariaDbSlaveCapability(2);
}
Configuration configuration = connectorConfig.getConfig();
client.setKeepAlive(configuration.getBoolean(MySqlConnectorConfig.KEEP_ALIVE));
final long keepAliveInterval = configuration.getLong(MySqlConnectorConfig.KEEP_ALIVE_INTERVAL_MS);

4
debezium-connector-mysql/src/test/java/io/debezium/connector/mysql/ReadBinLogIT.java
View File

@ -126,6 +126,10 @@ protected void startClient(Consumer<BinaryLogClient> preConnect) throws IOExcept
client.registerEventListener(counters);
client.registerEventListener(this::recordEvent);
client.registerLifecycleListener(new TraceLifecycleListener());
if (MySqlTestConnection.isMariaDb()) {
// This makes sure BEGIN events are emitted via QUERY events rather than GTIDs
client.setMariaDbSlaveCapability(2);
}
EventDeserializer eventDeserializer = new EventDeserializer();
eventDeserializer.setEventDataDeserializer(EventType.STOP, new StopEventDataDeserializer());
client.setEventDeserializer(eventDeserializer);