Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Response ¶
type Response struct {
// contains filtered or unexported fields
}
func Parse ¶
func Parse(msg []byte, requestApiKey, requestApiVersion int16, requestCorrelationId int32) (Response, error)
Parse deserializes this Kafka response
func (*Response) Data ¶
func (r *Response) Data() protocol.MessageData
func (*Response) HeaderData ¶
func (*Response) Release ¶
func (r *Response) Release()
Release releases the dynamically allocated fields of this object by returning then to object pools
func (*Response) Serialize ¶
Serialize serializes this Kafka response according to the given Kafka protocol version
func (*Response) SizeInBytes ¶
SizeInBytes returns the max size of this Kafka response in bytes when it's serialized
Click to show internal directories.
Click to hide internal directories.