/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

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