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

DBZ-5977 Quarkus can override Apicurio version

Browse Source
This commit is contained in:
Jiri Pechanec 2023-01-05 08:11:18 +01:00
parent 26bcb67cdc
commit 8fef5b6e54
3 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
debezium-server/debezium-server-bom/pom.xml
View File

@ -142,6 +142,18 @@
<version>${project.version}</version>
</dependency>
<!-- Quarkus BOM can override apicurio deps -->
<dependency>
<groupId>io.apicurio</groupId>
<artifactId>apicurio-registry-serdes-avro-serde</artifactId>
<version>${version.apicurio}</version>
</dependency>
<dependency>
<groupId>io.apicurio</groupId>
<artifactId>apicurio-registry-client</artifactId>
<version>${version.apicurio}</version>
</dependency>
<!-- Target systems -->
<dependency>
<groupId>software.amazon.awssdk</groupId>

3
debezium-server/debezium-server-core/pom.xml
View File

@ -52,7 +52,7 @@
<artifactId>quarkus-junit5</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<dependency>
<groupId>org.assertj</groupId>
<artifactId>assertj-core</artifactId>
<scope>test</scope></dependency>
@ -75,6 +75,7 @@
<dependency>
<groupId>io.apicurio</groupId>
<artifactId>apicurio-registry-utils-converter</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>io.confluent</groupId>

3
debezium-server/debezium-server-core/src/test/java/io/debezium/server/DebeziumServerWithApicurioIT.java
View File

@ -16,6 +16,7 @@
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.condition.EnabledIfSystemProperty;
import io.debezium.DebeziumException;
import io.debezium.server.events.ConnectorCompletedEvent;
import io.debezium.server.events.ConnectorStartedEvent;
import io.debezium.testing.testcontainers.PostgresTestResourceLifecycleManager;
@ -46,7 +47,7 @@ void setupDependencies(@Observes ConnectorStartedEvent event) {
void connectorCompleted(@Observes ConnectorCompletedEvent event) throws Exception {
if (!event.isSuccess()) {
throw (Exception) event.getError().get();
throw new DebeziumException(event.getError().get());
}
}