Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Use upstream DebeziumMetrics #111

Merged
merged 3 commits into from
Oct 1, 2022
Merged

Use upstream DebeziumMetrics #111

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
ae83bf7
Use upstream DebeziumMetrics
ismailsimsek Oct 1, 2022
4f1cf73
Use upstream DebeziumMetrics
ismailsimsek Oct 1, 2022
322e732
Use upstream DebeziumMetrics
ismailsimsek Oct 1, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
90 changes: 0 additions & 90 deletions debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/DebeziumMetrics.java
View file
Open in desktop

This file was deleted.

3 changes: 1 addition & 2 deletions ...iceberg-sink/src/main/java/io/debezium/server/iceberg/batchsizewait/MaxBatchSizeWait.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@

import io.debezium.DebeziumException;
import io.debezium.config.CommonConnectorConfig;
import io.debezium.server.iceberg.DebeziumMetrics;
import io.debezium.server.DebeziumMetrics;

import javax.enterprise.context.Dependent;
import javax.inject.Inject;
Expand Down Expand Up @@ -45,7 +45,6 @@ public class MaxBatchSizeWait implements InterfaceBatchSizeWait {
@Override
public void initizalize() throws DebeziumException {
assert waitIntervalMs < maxWaitMs : "`wait-interval-ms` cannot be bigger than `max-wait-ms`";
dbzMetrics.initizalize();
}

@Override
Expand Down
1 change: 0 additions & 1 deletion ...eberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMangodbTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,6 @@
import org.junit.jupiter.api.Test;

/**
* Integration test that verifies basic reading from PostgreSQL database and writing to s3 destination.
*
* @author Ismail Simsek
*/
Expand Down
1 change: 0 additions & 1 deletion ...iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerMysqlTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,6 @@
import org.junit.jupiter.api.Test;

/**
* Integration test that verifies basic reading from PostgreSQL database and writing to s3 destination.
*
* @author Ismail Simsek
*/
Expand Down
2 changes: 1 addition & 1 deletion ...rver-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@
import static org.junit.jupiter.api.Assertions.assertEquals;

/**
* Integration test that verifies basic reading from PostgreSQL database and writing to s3 destination.
* Integration test that verifies basic reading from PostgreSQL database and writing to iceberg destination.
*
* @author Ismail Simsek
*/
Expand Down
1 change: 0 additions & 1 deletion ...rc/test/java/io/debezium/server/iceberg/IcebergChangeConsumerUpsertDeleteDeletesTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,6 @@
import org.junit.jupiter.api.Test;

/**
* Integration test that verifies basic reading from PostgreSQL database and writing to s3 destination.
*
* @author Ismail Simsek
*/
Expand Down
1 change: 0 additions & 1 deletion ...ceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerUpsertTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,6 @@
import org.junit.jupiter.api.Test;

/**
* Integration test that verifies basic reading from PostgreSQL database and writing to s3 destination.
*
* @author Ismail Simsek
*/
Expand Down
1 change: 0 additions & 1 deletion ...ceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergEventsChangeConsumerTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,6 @@
import org.junit.jupiter.api.Test;

/**
* Integration test that verifies basic reading from PostgreSQL database and writing to s3.
*
* @author Ismail Simsek
*/
Expand Down
1 change: 0 additions & 1 deletion ...sink/src/test/java/io/debezium/server/iceberg/tableoperator/IcebergTableOperatorTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,6 @@


/**
* Integration test that verifies basic reading from PostgreSQL database and writing to s3 destination.
*
* @author Ismail Simsek
*/
Expand Down
4 changes: 2 additions & 2 deletions pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -38,10 +38,10 @@
<version.testcontainers>1.17.3</version.testcontainers>
<version.kafkaclients>3.2.1</version.kafkaclients>
<!-- Debezium -->
<version.debezium>1.9.5.Final</version.debezium>
<version.debezium>1.9.6.Final</version.debezium>
<version.mysql.driver>8.0.28</version.mysql.driver>
<!-- Quarkus -->
<version.quarkus>2.12.1.Final</version.quarkus>
<version.quarkus>2.12.3.Final</version.quarkus>
<!-- ANTLR -->
<!-- Align with Antlr runtime version pulled in via debezium -->
<version.antlr>4.8</version.antlr>
Expand Down