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

DBZ-3752 More suggested changes

Browse Source 
* Added `infinispan-buffer` profile for testing with infinispan
* Made `online_catalog` the default for testing
* Added protostream-processor back to the POM
This commit is contained in:
Chris Cranford 2021-07-29 04:36:58 -04:00 committed by Jiri Pechanec
parent 1c0b4fd5af
commit 709a50a652
3 changed files with 32 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
debezium-bom/pom.xml
View File

@ -42,6 +42,7 @@
<!-- Oracle dependencies -->
<version.infinispan>12.1.6.Final</version.infinispan>
<version.infinispan.protostream>4.4.1.Final</version.infinispan.protostream>
<!-- Tracing -->
<version.opentracing.strimzi>0.33.0</version.opentracing.strimzi>
@ -442,6 +443,12 @@
<artifactId>infinispan-core</artifactId>
<version>${version.infinispan}</version>
</dependency>
<dependency>
<groupId>org.infinispan.protostream</groupId>
<artifactId>protostream-processor</artifactId>
<version>${version.infinispan.protostream}</version>
<scope>provided</scope>
</dependency>
<!-- Testing utilities -->
<dependency>

16
debezium-connector-oracle/pom.xml
View File

@ -43,6 +43,10 @@
<groupId>org.infinispan</groupId>
<artifactId>infinispan-core</artifactId>
</dependency>
<dependency>
<groupId>org.infinispan.protostream</groupId>
<artifactId>protostream-processor</artifactId>
</dependency>
<!-- Testing -->
<dependency>
@ -103,6 +107,7 @@
<properties>
<adapter.name>logminer</adapter.name>
<log.mining.buffer.type.name>memory</log.mining.buffer.type.name>
</properties>
<build>
@ -138,6 +143,10 @@
<name>database.connection.adapter</name>
<value>${adapter.name}</value>
</property>
<property>
<name>log.mining.buffer.type</name>
<value>${log.mining.buffer.type.name}</value>
</property>
</systemProperties>
</configuration>
</plugin>
@ -165,6 +174,7 @@
<argLine>-Djava.library.path=${instantclient.dir} -Ddebezium.embedded.shutdown.pause.before.interrupt.ms=20000</argLine>
<systemPropertyVariables>
<database.connection.adapter>${adapter.name}</database.connection.adapter>
<log.mining.buffer.type>${log.mining.buffer.type.name}</log.mining.buffer.type>
</systemPropertyVariables>
</configuration>
</plugin>
@ -307,5 +317,11 @@
</dependency>
</dependencies>
</profile>
<profile>
<id>infinispan-buffer</id>
<properties>
<log.mining.buffer.type.name>infinispan</log.mining.buffer.type.name>
</properties>
</profile>
</profiles>
</project>

9
debezium-connector-oracle/src/test/java/io/debezium/connector/oracle/util/TestHelper.java
View File

@ -12,6 +12,7 @@
import io.debezium.config.Configuration;
import io.debezium.connector.oracle.OracleConnection;
import io.debezium.connector.oracle.OracleConnectorConfig;
import io.debezium.connector.oracle.OracleConnectorConfig.LogMiningBufferType;
import io.debezium.jdbc.JdbcConfiguration;
import io.debezium.relational.history.FileDatabaseHistory;
import io.debezium.util.Strings;
@ -108,6 +109,14 @@ public static Configuration.Builder defaultConfig() {
builder.withDefault(OracleConnectorConfig.XSTREAM_SERVER_NAME, "dbzxout");
}
else {
// Tests will always use the online catalog strategy due to speed.
builder.withDefault(OracleConnectorConfig.LOG_MINING_STRATEGY, "online_catalog");
final String bufferType = System.getProperty(OracleConnectorConfig.LOG_MINING_BUFFER_TYPE.name());
if (LogMiningBufferType.parse(bufferType).equals(LogMiningBufferType.INFINISPAN)) {
builder.withDefault(OracleConnectorConfig.LOG_MINING_BUFFER_TYPE, "infinispan");
builder.withDefault(OracleConnectorConfig.LOG_MINING_BUFFER_LOCATION, "./target/data");
}
builder.withDefault(OracleConnectorConfig.LOG_MINING_BUFFER_DROP_ON_STOP, true);
}