Skip to content
This repository has been archived by the owner on Oct 26, 2023. It is now read-only.

Latest commit

 

History

History
74 lines (55 loc) · 2.44 KB

README.md

File metadata and controls

74 lines (55 loc) · 2.44 KB

license GoDoc Build Status codecov Go Report Card

Go client for Schema Registry

A rewrite of Landdop/schema-registry for the Schema Registry v5.1.1 and above

Why ?

The Landdop/schema-registry project have been created in 2016 and a lot of things have changed since that time. This rewrite aims to be a more up-to-date client by adding the following features:

  • It keep the method signature similar to the Landoop client for an easy migration
  • It does support the contexts for all the requests
  • It support the v5.1.1 endpoints like the schema deletion and the compatibility checking
  • It keep its code simple
  • It leave the gzip managment to the go client
  • It keep everything tested
  • It propose a mock

Example

import "github.com/landoop/schema-registry"

client, _ := schemaregistry.NewClient("http://localhost:8081")
client.Subjects()

Or, to use with a Schema Registry endpoint listening on HTTPS:

import (
    "crypto/tls"
    "crypto/x509"
    "io/ioutil"

    "github.com/landoop/schema-registry"
)

// Create a TLS config to use to connect to Schema Registry. This config will permit TLS connections to an endpoint
// whose TLS cert is signed by the given caFile.
caCert, err := ioutil.ReadFile("/path/to/ca/file")
if err != nil {
    panic(err)
}

caCertPool := x509.NewCertPool()
caCertPool.AppendCertsFromPEM(caCert)

tlsConfig :=  &tls.Config{
    RootCAs:            caCertPool,
    InsecureSkipVerify: true,
}

httpsClientTransport := &http.Transport{
  TLSClientConfig: tlsConfig,
}

httpsClient := &http.Client{
  Transport: httpsClientTransport,
}

// Create the Schema Registry client
client, _ := schemaregistry.NewClient("https://localhost:8081", UsingClient(httpsClient))
client.Subjects()