protocol

type APIVersion struct {
	APIKey     int16
	MinVersion int16
	MaxVersion int16
}

type APIVersionsRequest struct {
	APIVersion int16
}

type APIVersionsResponse struct {
	APIVersion int16

	ErrorCode    int16
	APIVersions  []APIVersion
	ThrottleTime time.Duration
}

type AbortedTransaction struct {
	ProducerID  int64
	FirstOffset int64
}

type AlterConfigResourceResponse struct {
	ErrorCode    int16
	ErrorMessage *string
	Type         int8
	Name         string
}

type AlterConfigsEntry struct {
	Name  string
	Value *string
}

type AlterConfigsRequest struct {
	APIVersion int16

	Resources    []AlterConfigsResource
	ValidateOnly bool
}

type AlterConfigsResource struct {
	Type    int8
	Name    string
	Entries []AlterConfigsEntry
}

type AlterConfigsResponse struct {
	APIVersion int16

	ThrottleTime time.Duration
	Resources    []AlterConfigResourceResponse
}

type Body interface {
	Encoder
	Key() int16
	Version() int16
}

type Broker struct {
	NodeID int32
	Host   string
	Port   int32
	Rack   *string
}

type Brokers []*Broker

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

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

type CRCField struct {
	StartOffset int
}

type ControlledShutdownRequest struct {
	APIVersion int16
}

type ControlledShutdownResponse struct {
	APIVersion int16
}

type Coordinator struct {
	NodeID int32
	Host   string
	Port   int32
}

type CoordinatorType int8

type CreateTopicRequest struct {
	Topic             string
	NumPartitions     int32
	ReplicationFactor int16
	ReplicaAssignment map[int32][]int32
	Configs           map[string]*string
}

type CreateTopicRequests struct {
	APIVersion int16

	Requests     []*CreateTopicRequest
	Timeout      time.Duration
	ValidateOnly bool
}

type CreateTopicsResponse struct {
	APIVersion int16

	ThrottleTime    time.Duration
	TopicErrorCodes []*TopicErrorCode
}

type Data struct {
	Partition int32
	RecordSet []byte
}

type Datas []*Data

type Decoder interface {
	Decode(d PacketDecoder) error
}

type DeleteTopicsRequest struct {
	APIVersion int16

	Topics  []string
	Timeout time.Duration
}

type DeleteTopicsResponse struct {
	APIVersion int16

	ThrottleTime    time.Duration
	TopicErrorCodes []*TopicErrorCode
}

type DescribeConfigsEntry struct {
	Name        string
	Value       *string
	ReadOnly    bool
	IsDefault   bool
	IsSensitive bool
	Synonyms    []DescribeConfigsSynonym
}

type DescribeConfigsRequest struct {
	APIVersion int16

	Resources       []DescribeConfigsResource
	IncludeSynonyms bool
}

type DescribeConfigsResource struct {
	Type        int8
	Name        string
	ConfigNames []string
}

type DescribeConfigsResourceResponse struct {
	ErrorCode     int16
	ErrorMessage  *string
	Type          int8
	Name          string
	ConfigEntries []DescribeConfigsEntry
}

type DescribeConfigsResponse struct {
	APIVersion int16

	ThrottleTime time.Duration
	Resources    []DescribeConfigsResourceResponse
}

type DescribeConfigsSynonym struct {
	Name   string
	Value  *string
	Source int8
}

type DescribeGroupsRequest struct {
	APIVersion int16

	GroupIDs []string
}

type DescribeGroupsResponse struct {
	APIVersion int16

	ThrottleTime time.Duration
	Groups       []Group
}

type Encoder interface {
	Encode(e PacketEncoder) error
}

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

type FetchPartition struct {
	Partition   int32
	FetchOffset int64
	MaxBytes    int32
}

type FetchPartitionResponse struct {
	Partition           int32
	ErrorCode           int16
	HighWatermark       int64
	LastStableOffset    int64
	AbortedTransactions []*AbortedTransaction
	RecordSet           []byte
}

type FetchPartitionResponses []*FetchPartitionResponse

type FetchPartitions []*FetchPartition

type FetchRequest struct {
	APIVersion int16

	ReplicaID      int32
	MaxWaitTime    time.Duration
	MinBytes       int32
	MaxBytes       int32
	IsolationLevel IsolationLevel
	Topics         []*FetchTopic
}

type FetchResponse struct {
	APIVersion int16

	ThrottleTime time.Duration
	Responses    FetchTopicResponses
}

type FetchTopic struct {
	Topic      string
	Partitions []*FetchPartition
}

type FetchTopicResponse struct {
	Topic              string
	PartitionResponses FetchPartitionResponses
}

type FetchTopicResponses []*FetchTopicResponse

type FetchTopics []*FetchTopic

type FindCoordinatorRequest struct {
	APIVersion int16

	CoordinatorKey  string
	CoordinatorType CoordinatorType
}

type FindCoordinatorResponse struct {
	APIVersion int16

	ThrottleTime time.Duration
	ErrorCode    int16
	ErrorMessage *string
	Coordinator  Coordinator
}

type Group struct {
	ErrorCode    int16
	GroupID      string
	State        string
	ProtocolType string
	Protocol     string
	GroupMembers map[string]*GroupMember
}

type GroupAssignment struct {
	MemberID         string
	MemberAssignment []byte
}

type GroupMember struct {
	ClientID              string
	ClientHost            string
	GroupMemberMetadata   []byte
	GroupMemberAssignment []byte
}

type GroupProtocol struct {
	ProtocolName     string
	ProtocolMetadata []byte
}

type HeartbeatRequest struct {
	APIVersion int16

	GroupID           string
	GroupGenerationID int32
	MemberID          string
}

type HeartbeatResponse struct {
	APIVersion int16

	ThrottleTime time.Duration
	ErrorCode    int16
}

type Int32s []int32

type IsolationLevel int8

type JoinGroupRequest struct {
	APIVersion int16

	GroupID          string
	SessionTimeout   int32
	RebalanceTimeout int32
	MemberID         string
	ProtocolType     string
	GroupProtocols   []*GroupProtocol
}

type JoinGroupResponse struct {
	APIVersion int16

	ThrottleTime  time.Duration
	ErrorCode     int16
	GenerationID  int32
	GroupProtocol string
	LeaderID      string
	MemberID      string
	Members       []Member
}

type LeaderAndISRPartition struct {
	Topic     string
	Partition int32
	ErrorCode int16
}

type LeaderAndISRPartitions []*LeaderAndISRPartition

type LeaderAndISRRequest struct {
	APIVersion int16

	ControllerID    int32
	ControllerEpoch int32
	PartitionStates []*PartitionState
	LiveLeaders     []*LiveLeader
}

type LeaderAndISRResponse struct {
	APIVersion int16

	ErrorCode  int16
	Partitions []*LeaderAndISRPartition
}

type LeaveGroupRequest struct {
	APIVersion int16

	GroupID  string
	MemberID string
}

type LeaveGroupResponse struct {
	APIVersion int16

	ThrottleTime time.Duration
	ErrorCode    int16
}

type LenEncoder struct {
	Length int
	// contains filtered or unexported fields
}

type ListGroup struct {
	GroupID      string
	ProtocolType string
}

type ListGroupsRequest struct {
	APIVersion int16
}

type ListGroupsResponse struct {
	APIVersion int16

	ThrottleTime time.Duration
	ErrorCode    int16
	Groups       []ListGroup
}

type LiveLeader struct {
	ID   int32
	Host string
	Port int32
}

type LiveLeaders []*LiveLeader

type Member struct {
	MemberID       string
	MemberMetadata []byte
}

type Message struct {
	Crc        int32
	MagicByte  int8
	Attributes int8
	Timestamp  time.Time
	Key        []byte
	Value      []byte
}

type MessageSet struct {
	Offset                  int64
	Size                    int32
	Messages                []*Message
	PartialTrailingMessages bool
}

type MetadataRequest struct {
	APIVersion int16

	Topics                 []string
	AllowAutoTopicCreation bool
}

type MetadataResponse struct {
	APIVersion int16

	Brokers       []*Broker
	ControllerID  int32
	TopicMetadata []*TopicMetadata
}

type OffsetCommitPartitionRequest struct {
	Partition int32
	Offset    int64
	Timestamp int64
	Metadata  *string
}

type OffsetCommitPartitionResponse struct {
	Partition int32
	ErrorCode int16
}

type OffsetCommitRequest struct {
	APIVersion int16

	GroupID       string
	GenerationID  int32
	MemberID      string
	RetentionTime int64
	Topics        []OffsetCommitTopicRequest
}

type OffsetCommitResponse struct {
	APIVersion int16

	ThrottleTime time.Duration
	Responses    []OffsetCommitTopicResponse
}

type OffsetCommitTopicRequest struct {
	Topic      string
	Partitions []OffsetCommitPartitionRequest
}

type OffsetCommitTopicResponse struct {
	Topic              string
	PartitionResponses []OffsetCommitPartitionResponse
}

type OffsetFetchPartition struct {
	Partition int32
	Offset    int16
	Metadata  *string
	ErrorCode int16
}

type OffsetFetchRequest struct {
	APIVersion int16

	GroupID string
	Topics  []OffsetFetchTopicRequest
}

type OffsetFetchResponse struct {
	APIVersion int16

	Responses []OffsetFetchTopicResponse
}

type OffsetFetchTopicRequest struct {
	Topic      string
	Partitions []int32
}

type OffsetFetchTopicResponse struct {
	Topic      string
	Partitions []OffsetFetchPartition
}

type OffsetResponse struct {
	Topic              string
	PartitionResponses []*PartitionResponse
}

type OffsetsPartition struct {
	Partition     int32
	Timestamp     int64 // -1 to receive latest offset, -2 to receive earliest offset
	MaxNumOffsets int32
}

type OffsetsRequest struct {
	APIVersion int16

	ReplicaID      int32
	IsolationLevel int8
	Topics         []*OffsetsTopic
}

type OffsetsResponse struct {
	APIVersion int16

	ThrottleTime time.Duration
	Responses    []*OffsetResponse
}

type OffsetsTopic struct {
	Topic      string
	Partitions []*OffsetsPartition
}

type PacketDecoder interface {
	Bool() (bool, error)
	Int8() (int8, error)
	Int16() (int16, error)
	Int32() (int32, error)
	Int64() (int64, error)
	ArrayLength() (int, error)
	Bytes() ([]byte, error)
	String() (string, error)
	NullableString() (*string, error)
	Int32Array() ([]int32, error)
	Int64Array() ([]int64, error)
	StringArray() ([]string, error)
	Push(pd PushDecoder) error
	Pop() error
	// contains filtered or unexported methods
}

type PacketEncoder interface {
	PutBool(in bool)
	PutInt8(in int8)
	PutInt16(in int16)
	PutInt32(in int32)
	PutInt64(in int64)
	PutArrayLength(in int) error
	PutRawBytes(in []byte) error
	PutBytes(in []byte) error
	PutString(in string) error
	PutNullableString(in *string) error
	PutStringArray(in []string) error
	PutInt32Array(in []int32) error
	PutInt64Array(in []int64) error
	Push(pe PushEncoder)
	Pop()
}

type PartitionMetadata struct {
	PartitionErrorCode int16
	PartitionID        int32
	Leader             int32
	Replicas           []int32
	ISR                []int32
}

type PartitionMetadatas []*PartitionMetadata

type PartitionResponse struct {
	Partition int32
	ErrorCode int16
	Timestamp time.Time
	Offsets   []int64
	Offset    int64
}

type PartitionState struct {
	Topic           string
	Partition       int32
	ControllerEpoch int32
	Leader          int32
	LeaderEpoch     int32
	ISR             []int32
	ZKVersion       int32
	Replicas        []int32
	IsNew           bool
}

type PartitionStates []*PartitionState

type ProducePartitionResponse struct {
	Partition      int32
	ErrorCode      int16
	BaseOffset     int64
	LogAppendTime  time.Time
	LogStartOffset int64
}

type ProducePartitionResponses []*ProducePartitionResponse

type ProduceRequest struct {
	APIVersion int16

	TransactionalID *string
	Acks            int16
	Timeout         time.Duration
	TopicData       []*TopicData
}

type ProduceResponse struct {
	APIVersion int16

	Responses    []*ProduceTopicResponse
	ThrottleTime time.Duration
}

type ProduceTopicResponse struct {
	Topic              string
	PartitionResponses []*ProducePartitionResponse
}

type ProduceTopicResponses []*ProduceTopicResponse

type PushDecoder interface {
	SaveOffset(in int)
	ReserveSize() int
	Fill(curOffset int, buf []byte) error
	Check(curOffset int, buf []byte) error
}

type PushEncoder interface {
	SaveOffset(in int)
	ReserveSize() int
	Fill(curOffset int, buf []byte) error
}

type Request struct {
	CorrelationID int32
	ClientID      string
	Body          Body
}

type RequestHeader struct {
	// Size of the request
	Size int32
	// ID of the API (e.g. produce, fetch, metadata)
	APIKey int16
	// Version of the API to use
	APIVersion int16
	// User defined ID to correlate requests between server and client
	CorrelationID int32
	// Size of the Client ID
	ClientID string
}

type Response struct {
	Size          int32
	CorrelationID int32
	Body          ResponseBody
}

type ResponseBody interface {
	Encoder
	VersionedDecoder
}

type SaslHandshakeRequest struct {
	APIVersion int16
}

type SaslHandshakeResponse struct{}

type SizeField struct {
	StartOffset int
}

type StopReplicaPartition struct {
	Topic     string
	Partition int32
}

type StopReplicaRequest struct {
	APIVersion       int16
	ControllerID     int32
	ControllerEpoch  int32
	DeletePartitions bool
	Partitions       []*StopReplicaPartition
}

type StopReplicaResponse struct {
	ErrorCode  int16
	Partitions []*StopReplicaResponsePartition
}

type StopReplicaResponsePartition struct {
	Topic     string
	Partition int32
	ErrorCode int16
}

type Strings []string

type SyncGroupRequest struct {
	APIVersion int16

	GroupID          string
	GenerationID     int32
	MemberID         string
	GroupAssignments []GroupAssignment
}

type SyncGroupResponse struct {
	APIVersion int16

	ThrottleTime     time.Duration
	ErrorCode        int16
	MemberAssignment []byte
}

type TopicData struct {
	Topic string
	Data  []*Data
}

type TopicDatas []*TopicData

type TopicErrorCode struct {
	Topic        string
	ErrorCode    int16
	ErrorMessage *string
}

type TopicMetadata struct {
	TopicErrorCode    int16
	Topic             string
	IsInternal        bool
	PartitionMetadata []*PartitionMetadata
}

type TopicMetadatas []*TopicMetadata

type UpdateMetadataRequest struct {
	APIVersion int16
}

type UpdateMetadataResponse struct {
}

type VersionedDecoder interface {
	Decode(d PacketDecoder, version int16) error
}