A module designed to simplify and unify Apache Kafka message processing
Go modules are supported.
Manual install:
go get -u github.com/alebabai/go-kafka
Golang import:
import "github.com/alebabai/go-kafka"
To use the abstractions provided by this module, please implement the converters defined in adapter/converter.go for the types specific to your Apache Kafka client library.
Additionally, here is an adapter implementation for the most popular Apache Kafka client library, github.com/Shopify/sarama. The module, named github.com/alebabai/go-kafka/adapter/sarama, can be used independently or as a reference example.