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

DBZ-7065 Apply suggestions from code review

Browse Source 
Co-authored-by: Jiri Pechanec <jpechane@redhat.com>
This commit is contained in:
Roman Kudryashov 2023-11-08 18:24:59 +03:00 committed by Jiri Pechanec
parent eadd60625f
commit 1d35107283
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
debezium-connector-jdbc/src/main/java/io/debezium/connector/jdbc/transform/ConvertCloudEventToSaveableForm.java
View File

@ -81,7 +81,7 @@ private Map<String, String> parseFieldsMapping(List<String> rawFieldsMapping) {
final String[] parts = rawFieldMapping.split(FIELD_NAME_SEPARATOR);
final String cloudEventFieldName = parts[0];
final String databaseColumnName;
if (rawFieldMapping.contains(FIELD_NAME_SEPARATOR)) {
if (parts.length > 1) {
databaseColumnName = parts[1];
}
else {
@ -94,8 +94,8 @@ private Map<String, String> parseFieldsMapping(List<String> rawFieldsMapping) {
@Override
public SinkRecord apply(final SinkRecord record) {
if (!record.valueSchema().name().endsWith(CLOUD_EVENTS_SCHEMA_NAME_SUFFIX) || fieldsMapping.isEmpty()) {
return null;
if (record == null || !record.valueSchema().name().endsWith(CLOUD_EVENTS_SCHEMA_NAME_SUFFIX) || fieldsMapping.isEmpty()) {
return record;
}
final org.apache.kafka.connect.data.Field dataField = record.valueSchema().field(CloudEventsMaker.FieldName.DATA);