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

DBZ-2975 Formatting

Browse Source
This commit is contained in:
Gunnar Morling 2021-06-09 15:22:52 +02:00
parent 1ce65fa628
commit dc865cd82d
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
debezium-connector-postgres/src/main/java/io/debezium/connector/postgresql/PostgresConnectorTask.java
View File

@ -197,7 +197,7 @@ public ChangeEventSourceCoordinator<PostgresOffsetContext> start(Configuration c
schemaNameAdjuster,
jdbcConnection);
ChangeEventSourceCoordinator<PostgresOffsetContext> coordinator = new PostgresChangeEventSourceCoordinator (
ChangeEventSourceCoordinator<PostgresOffsetContext> coordinator = new PostgresChangeEventSourceCoordinator(
previousOffset,
errorHandler,
PostgresConnector.class,

2
debezium-core/src/main/java/io/debezium/pipeline/ChangeEventSourceCoordinator.java
View File

@ -83,7 +83,7 @@ public ChangeEventSourceCoordinator(O previousOffset, ErrorHandler errorHandler,
}
public synchronized void start(CdcSourceTaskContext taskContext, ChangeEventQueueMetrics changeEventQueueMetrics,
EventMetadataProvider metadataProvider) {
EventMetadataProvider metadataProvider) {
AtomicReference<LoggingContext.PreviousContext> previousLogContext = new AtomicReference<>();
try {
this.snapshotMetrics = changeEventSourceMetricsFactory.getSnapshotMetrics(taskContext, changeEventQueueMetrics, metadataProvider);