go-kit-kafka

module
v1.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 14, 2024 License: MIT

README

go-kit-kafka

Apache Kafka integration module for go-kit

build version report coverage tag reference

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"

Usage

To use consumer/producer transport abstractions converters to the following types from the chosen Apache Kafka client library should be implemented:

type Message struct {
    Topic     string
    Partition int32
    Offset    int64
    Key       []byte
    Value     []byte
    Headers   []Header
    Timestamp time.Time
}

type Header struct {
    Key   []byte
    Value []byte
}

Examples

Go to Examples.

Directories

Path Synopsis
examples
common Module
confluent Module
sarama Module
Package kafka package contains type definitions to describe the Apache Kafka transport in terms of Go-Kit abstractions.
Package kafka package contains type definitions to describe the Apache Kafka transport in terms of Go-Kit abstractions.
tracing
Package tracing provides helpers and bindings for distributed tracing of Apache Kafka consumers and producers.
Package tracing provides helpers and bindings for distributed tracing of Apache Kafka consumers and producers.
tracing/opentracing
Package opentracing provides Go kit integration in term of transport layer for Apache Kafka to the OpenTracing project.
Package opentracing provides Go kit integration in term of transport layer for Apache Kafka to the OpenTracing project.
transport
Package transport provides a Kafka transport abstraction.
Package transport provides a Kafka transport abstraction.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL