go-kit-kafka

README

go-kit-kafka

Apache Kafka integration module for go-kit

Getting started

Go modules are supported.

Manual install:

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

Golang import:

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

Reference

TBD

Usage

Consumer

To use consumer transport abstractions the following adapters for the chosen Apache Kafka client library should be implemented:

type Message interface {
	Topic() string
	Partition() int
	Offset() int64
	Key() []byte
	Value() []byte
	Headers() []Header
	Timestamp() time.Time
}


type Header interface {
	Key() string
	Value() []byte
}


type Reader interface {
	ReadMessage(ctx context.Context) (Message, error)
	Committer
	io.Closer
}

type Committer interface {
    Commit(ctx context.Context) error
}

Examples

Go to Examples.