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

DBZ-8011 Small naming refactor

Browse Source
This commit is contained in:
Chris Cranford 2024-07-15 15:08:17 -04:00 committed by Chris Cranford
parent 1039ccfcf2
commit 3bd71a5e69
2 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
debezium-connector-mongodb/src/main/java/io/debezium/connector/mongodb/MongoDbConnectorConfig.java
View File

@ -1428,14 +1428,14 @@ private static int resolveSnapshotMaxThreads(Configuration config) {
@Override
public Optional<String[]> parseSignallingMessage(Struct value, String fieldName) {
final String after = value.getString(fieldName);
if (after == null) {
LOGGER.warn("After part of signal '{}' is missing", value);
final String event = value.getString(fieldName);
if (event == null) {
LOGGER.warn("Field {} part of signal '{}' is missing", fieldName, value);
return Optional.empty();
}
final Document fields = Document.parse(after);
final Document fields = Document.parse(event);
if (fields.size() != 3) {
LOGGER.warn("The signal event '{}' should have 3 fields but has {}", after, fields.size());
LOGGER.warn("The signal event '{}' should have 3 fields but has {}", event, fields.size());
return Optional.empty();
}
final String[] result = new String[3];

16
debezium-core/src/main/java/io/debezium/config/CommonConnectorConfig.java
View File

@ -1621,20 +1621,20 @@ public List<String> getEnabledChannels() {
}
public Optional<String[]> parseSignallingMessage(Struct value, String fieldName) {
final Struct after = value.getStruct(fieldName);
if (after == null) {
LOGGER.warn("After part of signal '{}' is missing", value);
final Struct event = value.getStruct(fieldName);
if (event == null) {
LOGGER.warn("Field {} part of signal '{}' is missing", fieldName, value);
return Optional.empty();
}
List<org.apache.kafka.connect.data.Field> fields = after.schema().fields();
List<org.apache.kafka.connect.data.Field> fields = event.schema().fields();
if (fields.size() != 3) {
LOGGER.warn("The signal event '{}' should have 3 fields but has {}", after, fields.size());
LOGGER.warn("The signal event '{}' should have 3 fields but has {}", event, fields.size());
return Optional.empty();
}
return Optional.of(new String[]{
after.getString(fields.get(0).name()),
after.getString(fields.get(1).name()),
after.getString(fields.get(2).name())
event.getString(fields.get(0).name()),
event.getString(fields.get(1).name()),
event.getString(fields.get(2).name())
});
}