Documentação do Oracle Cloud Infrastructure

Importando de Outras Instâncias do Big Data Service

Use a ferramenta de importação de esquema ao migrar o esquema do Confluent Schema Registry para o Big Data Service Schema Registry.

A ferramenta de importação importa todos os esquemas e versões do Registro de Esquema Confluent para o Banco de Dados de Registro de Esquema do Big Data Service.

  1. Antes de usar a ferramenta de importação, certifique-se de que os esquemas sejam exportados do Confluent Schema Registry.
    Observação

    No Confluent Schema Registry, todos os Esquemas são armazenados em um tópico called _schema.
  2. Exportar os esquemas: 
    /usr/odh/currect/kafka-broker/bin/kafka-console-consumer.sh --from-beginning --topic schemas --formatter kafka.tools.DefaultMessageFormatter --property print.key=true --property print.value=true --bootstrap-server `broker hostname`:6667

    Saída de amostra:

    {"keytype":"SCHEMA","subject":"test-1","version":1,"magic":1}    {"subject":"test-1","version":1,"id":1,"schema":"{\"type\":\"record\",\"name\":\"Person\",\"namespace\":\"flink.parquet.avro\",\"fields\":[{\"name\":\"name\",\"type\":\"string\"},{\"name\":\"id\",\"type\":\"int\"},{\"name\":\"email\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"phone\",\"type\":{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"PhoneNumber\",\"fields\":[{\"name\":\"number\",\"type\":\"string\"}","deleted":false}
{"keytype":"SCHEMA","subject":"test-2","version":1,"magic":1}    {"subject":"test-2","version":2,"id":1,"schema":"{\"type\":\"record\",\"name\":\"Person\",\"namespace\":\"flink.parquet.avro\",\"fields\":[{\"name\":\"name\",\"type\":\"string\"},{\"name\":\"id\",\"type\":\"int\"},{\"name\":\"email\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"phone\",\"type\":{\"type\":\"array\",\"items\":{\"type\":\"record\",\"name\":\"PhoneNumber\",\"fields\":[{\"name\":\"number\",\"type\":\"string\"}","deleted":false}
  3. Copie essa saída para um arquivo de texto a ser importado para o Registro de Esquema do Big Data Service.
  4. Importe este esquema usando a ferramenta de importação e executando o seguinte comando curl: 
    curl --negotiate -u : --form file='@/path/to/exported/schema/schema.txt' 'http://<BDS Schema registry FQDN>:9093/api/v2/schemaregistry/import?format=1&failOnError=true' -X 'POST'

    Onde:

    • /path/to/exported/schema/schema.txt: O caminho local para o esquema exportado.
    • format=1: Isso é para importação de esquema Confluent. Outra opção é format=0 para importar esquemas de outras instâncias do Registro de Esquema do Big Data Service.
    • v2: A versão V2 da API para importação do Confluent. A versão V1 da API também está disponível.
    • failOnError: Se definido como verdadeiro, a importação falhará se uma importação da versão do esquema falhar.