kafka

Documentation

Index

• type Handler
• type Header
• type Message

Types

type Handler

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

type Header

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

type Message

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