check message is not null before write
@@ -102,8 +102,10 @@ public class ProtobufParquetFileReaderWriterFactory implements FileReaderWriterF
@Override
public void write(KeyValue keyValue) throws IOException {
Message message = protobufUtil.decodeMessage(topic, keyValue.getValue());
+ if (message != null) {
writer.write(message);
}
+ }
@Override
public void close() throws IOException {
