go-kafka-avro

A library provides consumer/producer to work with kafka, avro and schema registry

Installation

$ go get github.com/dangkaka/go-kafka-avro

Usage

Consumer/producer examples stay here

cd dangkaka/go-kafka-avro/examples

• Setup kafka, schema-registry

  docker-compose up -d
  

• Add test messages

  go run producer/main.go -n 10
  

• Run consumer

  go run consumer/main.go
  

References

• Kafka sarama
• Encodes and decodes Avro data goavro
• Consumer group sarama-cluster
• schema-registry