/go-kafka-avro

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

Primary LanguageGoApache License 2.0Apache-2.0

codecov CircleCI

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