thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-21 01:00:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

AvroConfluent: skip tombstone records

Browse Source
This commit is contained in:
Andrew Onyshchuk 2020-07-30 23:42:24 -05:00
parent d4266d9619
commit 99c183da0f
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/Processors/Formats/Impl/AvroRowInputFormat.cpp
View File

@ -727,6 +727,11 @@ bool AvroConfluentRowInputFormat::readRow(MutableColumns & columns, RowReadExten
{
return false;
}
// skip tombstone records (kafka messages with null value)
if (in.available() == 0)
{
return false;
}
SchemaId schema_id = readConfluentSchemaId(in);
const auto & deserializer = getOrCreateDeserializer(schema_id);
deserializer.deserializeRow(columns, *decoder, ext);