kafka

Documentation

Index

• func IsReadTimeout(msg *ck.Message, err error) bool
• func RemoveHeaders(headerNames []string, msg *ck.Message)
• func SearchHeaderValue(headers []ck.Header, key string) []byte
• type Consumer
• type Producer

Functions

func IsReadTimeout

func IsReadTimeout(msg *ck.Message, err error) bool

func RemoveHeaders

func RemoveHeaders(headerNames []string, msg *ck.Message)

func SearchHeaderValue

func SearchHeaderValue(headers []ck.Header, key string) []byte

Types

type Consumer

type Consumer interface {
	ReadMessage(time.Duration) (*ck.Message, error)
	Subscribe(string, ck.RebalanceCb) error
	SubscribeTopics(topics []string, rebalanceCb ck.RebalanceCb) (err error)
	Seek(partition ck.TopicPartition, timeoutMs int) error
	CommitMessage(*ck.Message) ([]ck.TopicPartition, error)
	Pause([]ck.TopicPartition) (err error)
	Resume([]ck.TopicPartition) (err error)
	Close() error
}

type Producer

type Producer interface {
	Close()
	Produce(*ck.Message, chan ck.Event) error
}