diff --git a/src/Command/RegisterChangedSchemasCommand.php b/src/Command/RegisterChangedSchemasCommand.php index 5cfe95b..ae1c546 100644 --- a/src/Command/RegisterChangedSchemasCommand.php +++ b/src/Command/RegisterChangedSchemasCommand.php @@ -149,12 +149,13 @@ private function registerFiles( } try { - $this->schemaRegistryApi->registerNewSchemaVersion($schemaName, $localSchema); - } catch (\Throwable $e) { + AvroSchema::parse($localSchema); + } catch (AvroSchemaParseException $e) { $io->writeln(sprintf('Skipping %s for now because %s', $schemaName, $e->getMessage())); $failed[$schemaName] = $schemaName; continue; } + $this->schemaRegistryApi->registerNewSchemaVersion($schemaName, $localSchema); $succeeded[$schemaName] = [ 'name' => $schemaName,