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

DBZ-8103 Fix obtaining data when optional header is not present

Browse Source
This commit is contained in:
Roman Kudryashov 2024-08-05 09:53:37 +03:00 committed by Jiri Pechanec
parent 7cc70da4b2
commit 8c98c979c7
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
debezium-core/src/main/java/io/debezium/converters/recordandmetadata/RecordAndMetadataHeaderImpl.java
View File

@ -93,9 +93,14 @@ private <T> T getValueFromHeaderOrByDefault(MetadataSourceValue metadataSourceVa
private SchemaAndValue getHeaderSchemaAndValue(Headers headers, String headerName, boolean isOptional) {
Header header = headers.lastHeader(headerName);
if (header == null && !isOptional) {
if (header == null) {
if (isOptional) {
return SchemaAndValue.NULL;
}
else {
throw new RuntimeException("Header `" + headerName + "` was not provided");
}
}
return jsonHeaderConverter.toConnectData(null, header.value());
}
}