go-kafka

A middleware that unifies Apache Kafka message processing across various libraries

Getting started

Go modules are supported.

Manual install:

go get -u github.com/alebabai/go-kafka

Golang import:

import "github.com/alebabai/go-kafka"

Usage

To use the abstractions provided by this module, just implement the converters defined in adapter/converter.go for the types specific to your Apache Kafka client library.

By the way, here are the implementations for the most popular Apache Kafka client libraries that can be used independently or as reference examples.

• IBM/sarama (alebabai/go-kafka/adapter/sarama)
• confluentinc/confluent-kafka-go (alebabai/go-kafka/adapter/confluent)