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