streams

Documentation

Index

• Variables
• type PacketDecoder
  • func NewDecoder(raw []byte) PacketDecoder
• type SubscriptionInfo
  • func (s *SubscriptionInfo) Decode(pd PacketDecoder) (err error)
• type TaskID

Variables

var ErrInsufficientData = errors.New("kafka: insufficient data to decode packet, more bytes expected")

ErrInsufficientData is returned when decoding and the packet is truncated. This can be expected when requesting messages, since as an optimization the server is allowed to return a partial message at the end of the message set.

Types

type PacketDecoder

type PacketDecoder interface {
	// contains filtered or unexported methods
}

func NewDecoder

func NewDecoder(raw []byte) PacketDecoder

type SubscriptionInfo

type SubscriptionInfo struct {
	Version      int32
	UUID         []byte // 16-byte UUID
	ProcessID    string
	PrevTasks    []TaskID
	StandbyTasks []TaskID
	UserEndpoint string
}

func (*SubscriptionInfo) Decode

func (s *SubscriptionInfo) Decode(pd PacketDecoder) (err error)

Support version 1+2

type TaskID

type TaskID struct {
	TopicGroupID int32
	Partition    int32
}