/avronats

Go Avro Encoder for NATS messaging system

Primary LanguageGoApache License 2.0Apache-2.0

Build Status

avronats

Go Avro Encoder for NATS messaging system.

How to use

  nc, _ := nats.Connect(nats.DefaultURL)
  encoder := avronats.NewAvroEncoder(schemaRegistryURL)
  nats.RegisterEncoder("avro", encoder)
  c, err := nats.NewEncodedConn(nc, "avro")
  //...