kafka

Documentation

Overview

Package kafka package contains type definitions to describe the Apache Kafka transport in terms of Go-Kit abstractions.

Index

• type Handler
• type Header
• type Message

Types

type Handler

type Handler interface {
	Handle(ctx context.Context, msg *Message) error
}

Handler is an interface for processing Kafka messages.

type Header

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

Header is a Kafka message object.

type Message

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

Message is a Kafka message object.