SQL Stream BuilderPDF version

Adding Schema Registry as Catalog

After installing Schema Registry as a service on your cluster, you can add it as a Catalog in SQL Stream Builder (SSB) to use it in Flink DDL.

  • Make sure that you have Schema Registry service on your cluster.
  1. Go to your cluster in Cloudera Manager.
  2. Click SQL Stream Builder from the list of services.
  3. Click SQLStreamBuilder Console.
    The Streaming SQL Console opens in a new window.
  4. Click Data Providers from the main menu.
  5. Click Register Catalog.
    The Add Catalog window appears.
  6. Add a Name to your catalog.
  7. Select Schema Registry from the Catalog Type drop-down.
  8. Select the Kafka cluster you registered as Data Provider.
  9. Add the Schema Registry URL.
    1. Go to your cluster in Cloudera Manager.
    2. Select Schema Registry from the list of services.
    3. Click on Instances.
    4. Copy the Hostname of Schema Registry.
    5. Add the default port of Schema Registry after the hostname.
      Example:
      http://docs-test-1.vpc.cloudera.com:7788/api/v1
  10. Select if you wan to enable TLS for Schema Registry.
    1. If yes, provide the Schema Registry Truststore location and password.
  11. Click on Add Filter.
    1. Provide a Database and Table filter if you want to select specific tables to use from the catalog.
  12. Click on Validate.
  13. If the validation is successful, click Add Tables.
Schema Registry is added as a Catalog and ready to be used in Flink DDL. The already existing schemas in Schema Registry are automatically imported to SSB.

We want your opinion

How can we improve this page?

What kind of feedback do you have?