api

Documentation

Overview

Package api defines Kafka protocol requests and responses.

Package api defines Kafka protocol requests and responses.

Index

• Constants
• Variables
• type Request
  • func (r *Request) Bytes() []byte
• type Response
  • func Read(r io.Reader) (*Response, error)
  • func (r *Response) Bytes() []byte
  • func (r *Response) CorrelationId() int32
  • func (r *Response) Unmarshal(v interface{}) error

Constants

const (
	Produce                 int16 = 0 // 1_0:5 2_3:7
	Fetch                         = 1 // 1_0:6
	ListOffsets                   = 2 // 1_0:2
	Metadata                      = 3 // 1_0:5
	LeaderAndIsr                  = 4
	StopReplica                   = 5
	UpdateMetadata                = 6
	ControlledShutdown            = 7
	OffsetCommit                  = 8  // 1_0:3
	OffsetFetch                   = 9  // 1_0:3
	FindCoordinator               = 10 // 1_0:1
	JoinGroup                     = 11 // 1_0:2
	Heartbeat                     = 12 // 1_0:1
	LeaveGroup                    = 13
	SyncGroup                     = 14 // 1_0:1
	DescribeGroups                = 15
	ListGroups                    = 16
	SaslHandshake                 = 17
	ApiVersions                   = 18 // 1_0:1
	CreateTopics                  = 19 // 1_0:2
	DeleteTopics                  = 20
	DeleteRecords                 = 21
	InitProducerId                = 22
	OffsetForLeaderEpoch          = 23
	AddPartitionsToTxn            = 24
	AddOffsetsToTxn               = 25
	EndTxn                        = 26
	WriteTxnMarkers               = 27
	TxnOffsetCommit               = 28
	DescribeAcls                  = 29
	CreateAcls                    = 30
	DeleteAcls                    = 31
	DescribeConfigs               = 32
	AlterConfigs                  = 33
	AlterReplicaLogDirs           = 34
	DescribeLogDirs               = 35
	SaslAuthenticate              = 36
	CreatePartitions              = 37
	CreateDelegationToken         = 38
	RenewDelegationToken          = 39
	ExpireDelegationToken         = 40
	DescribeDelegationToken       = 41
	DeleteGroups                  = 42
	ElectPreferredLeaders         = 43
)

Variables

var Keys = map[int]string{
	0:  "Produce",
	1:  "Fetch",
	2:  "ListOffsets",
	3:  "Metadata",
	4:  "LeaderAndIsr",
	5:  "StopReplica",
	6:  "UpdateMetadata",
	7:  "ControlledShutdown",
	8:  "OffsetCommit",
	9:  "OffsetFetch",
	10: "FindCoordinator",
	11: "JoinGroup",
	12: "Heartbeat",
	13: "LeaveGroup",
	14: "SyncGroup",
	15: "DescribeGroups",
	16: "ListGroups",
	17: "SaslHandshake",
	18: "ApiVersions",
	19: "CreateTopics",
	20: "DeleteTopics",
	21: "DeleteRecords",
	22: "InitProducerId",
	23: "OffsetForLeaderEpoch",
	24: "AddPartitionsToTxn",
	25: "AddOffsetsToTxn",
	26: "EndTxn",
	27: "WriteTxnMarkers",
	28: "TxnOffsetCommit",
	29: "DescribeAcls",
	30: "CreateAcls",
	31: "DeleteAcls",
	32: "DescribeConfigs",
	33: "AlterConfigs",
	34: "AlterReplicaLogDirs",
	35: "DescribeLogDirs",
	36: "SaslAuthenticate",
	37: "CreatePartitions",
	38: "CreateDelegationToken",
	39: "RenewDelegationToken",
	40: "ExpireDelegationToken",
	41: "DescribeDelegationToken",
	42: "DeleteGroups",
	43: "ElectPreferredLeaders",
}

Types

type Request

type Request struct {
	ApiKey        int16
	ApiVersion    int16
	CorrelationId int32
	ClientId      string
	Body          interface{}
}

func (*Request) Bytes

func (r *Request) Bytes() []byte

type Response

type Response struct {
	// contains filtered or unexported fields
}

func Read

func Read(r io.Reader) (*Response, error)

func (*Response) Bytes

func (r *Response) Bytes() []byte

func (*Response) CorrelationId

func (r *Response) CorrelationId() int32

func (*Response) Unmarshal

func (r *Response) Unmarshal(v interface{}) error