class AvroSchemaTranslator implements ConnectSchemaTranslator {

  @Override
  public ParsedSchema fromConnectSchema(final Schema schema) {
    final Schema avroCompatibleSchema = AvroSchemas
        .getAvroCompatibleConnectSchema(schema, formatProps.getFullSchemaName());

    try {
      return new AvroSchema(avroData.fromConnectSchema(avroCompatibleSchema));
    } catch (final SchemaParseException e) {
      throw new KsqlException("Schema is not compatible with Avro: " + e.getMessage(), e);
    }
  }

    AvroSchemaTranslator(final AvroProperties formatProps);

}