kafka

Documentation

Index

• func Example()
• type Consumer
  • func NewConsumer(brokers []string, topics map[string]MsgCallback) (Consumer, error)
• type KafkaTxQueue
• type MsgCallback
• type Producer
  • func NewProducer(brokers []string, queue chan KafkaTxQueue) (Producer, error)

Functions

func Example

func Example()

Types

type Consumer

type Consumer interface {
	Serve(ctx context.Context)
	Close()
}

func NewConsumer

func NewConsumer(brokers []string, topics map[string]MsgCallback) (Consumer, error)

type KafkaTxQueue

type KafkaTxQueue struct {
	Topic string
	Data  []byte
}

type MsgCallback

type MsgCallback chan []byte

type Producer

type Producer interface {
	Send(topic string, data []byte) error
	Serve()
	Shutdown() error
}

func NewProducer

func NewProducer(brokers []string, queue chan KafkaTxQueue) (Producer, error)