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

DBZ-6463 Fix formatting

Browse Source
This commit is contained in:
Jiri Pechanec 2023-06-13 08:20:35 +02:00
parent c4a1afc892
commit a5a241d198
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
debezium-connector-jdbc/src/main/java/io/debezium/connector/jdbc/JdbcSinkConnectorTask.java
View File

@ -12,7 +12,6 @@
import java.util.concurrent.atomic.AtomicReference;
import java.util.concurrent.locks.ReentrantLock;
import io.debezium.util.Strings;
import org.apache.kafka.clients.consumer.OffsetAndMetadata;
import org.apache.kafka.common.TopicPartition;
import org.apache.kafka.connect.errors.ConnectException;
@ -23,6 +22,7 @@
import org.slf4j.LoggerFactory;
import io.debezium.pipeline.sink.spi.ChangeEventSink;
import io.debezium.util.Strings;
/**
* The main task executing streaming from sink connector.
@ -194,7 +194,7 @@ private String getOriginalTopicName(SinkRecord record) {
if (record instanceof InternalSinkRecord) {
return ((InternalSinkRecord) record).originalRecord().topic();
}
return null;
return null;
}
}