codec

type ApiCode int16

type ApiReq struct {
	BaseReq
	ClientSoftwareName    string
	ClientSoftwareVersion string
}

type ApiResp struct {
	BaseResp
	ErrorCode       ErrorCode
	ApiRespVersions []*ApiRespVersion
	ThrottleTime    int
}

type ApiRespVersion struct {
	ApiKey     ApiCode
	MinVersion int16
	MaxVersion int16
}

type BaseReq struct {
	ApiVersion    int16
	CorrelationId int
	ClientId      string
}

type BaseResp struct {
	CorrelationId int
}

type BrokerMetadata struct {
	NodeId int32
	Host   string
	Port   int
	Rack   *string
}

type EnableMechanism struct {
	SaslMechanism string
}

type ErrorCode int16

type FetchPartitionReq struct {
	PartitionId        int
	CurrentLeaderEpoch int32
	FetchOffset        int64
	LastFetchedEpoch   int
	LogStartOffset     int64
	PartitionMaxBytes  int
}

type FetchPartitionResp struct {
	PartitionIndex      int
	ErrorCode           ErrorCode
	HighWatermark       int64
	LastStableOffset    int64
	LogStartOffset      int64
	AbortedTransactions int64
	ReplicaId           int32
	RecordBatch         *RecordBatch
}

type FetchReq struct {
	BaseReq
	ReplicaId         int32
	MaxWaitTime       int
	MinBytes          int
	MaxBytes          int
	IsolationLevel    byte
	FetchSessionId    int
	FetchSessionEpoch int32
	TopicReqList      []*FetchTopicReq
}

type FetchResp struct {
	BaseResp
	ThrottleTime  int
	ErrorCode     ErrorCode
	SessionId     int
	TopicRespList []*FetchTopicResp
}

type FetchTopicReq struct {
	Topic            string
	PartitionReqList []*FetchPartitionReq
}

type FetchTopicResp struct {
	Topic             string
	PartitionRespList []*FetchPartitionResp
}

type FindCoordinatorReq struct {
	BaseReq
	Key     string
	KeyType byte
}

type FindCoordinatorResp struct {
	BaseResp
	ErrorCode    ErrorCode
	ThrottleTime int
	ErrorMessage *string
	NodeId       int32
	Host         string
	Port         int
}

type GroupAssignment struct {
	MemberId         string
	MemberAssignment []byte
}

type GroupProtocol struct {
	ProtocolName     string
	ProtocolMetadata []byte
}

type Header struct {
	Key   string
	Value []byte
}

type HeartbeatReq struct {
	BaseReq
	GroupId         string
	GenerationId    int
	MemberId        string
	GroupInstanceId *string
}

type HeartbeatResp struct {
	BaseResp
	ErrorCode    ErrorCode
	ThrottleTime int
}

type JoinGroupReq struct {
	BaseReq
	GroupId          string
	SessionTimeout   int
	RebalanceTimeout int
	MemberId         string
	GroupInstanceId  *string
	ProtocolType     string
	GroupProtocols   []*GroupProtocol
}

type JoinGroupResp struct {
	BaseResp
	ErrorCode    ErrorCode
	ThrottleTime int
	GenerationId int
	ProtocolType *string
	ProtocolName string
	LeaderId     string
	MemberId     string
	Members      []*Member
}

type LeaveGroupMember struct {
	MemberId        string
	GroupInstanceId *string
}

type LeaveGroupReq struct {
	BaseReq
	GroupId string
	Members []*LeaveGroupMember
}

type LeaveGroupResp struct {
	BaseResp
	ErrorCode       ErrorCode
	ThrottleTime    int
	Members         []*LeaveGroupMember
	MemberErrorCode ErrorCode
}

type ListOffsetsPartition struct {
	PartitionId int
	LeaderEpoch int32
	Time        int64
}

type ListOffsetsPartitionResp struct {
	PartitionId int
	ErrorCode   ErrorCode
	Timestamp   int64
	Offset      int64
	LeaderEpoch int32
}

type ListOffsetsReq struct {
	BaseReq
	ReplicaId      int32
	IsolationLevel byte
	TopicReqList   []*ListOffsetsTopic
}

type ListOffsetsResp struct {
	BaseResp
	ErrorCode     ErrorCode
	ThrottleTime  int
	TopicRespList []*ListOffsetsTopicResp
}

type ListOffsetsTopic struct {
	Topic            string
	PartitionReqList []*ListOffsetsPartition
}

type ListOffsetsTopicResp struct {
	Topic             string
	PartitionRespList []*ListOffsetsPartitionResp
}

type Member struct {
	MemberId        string
	GroupInstanceId *string
	Metadata        []byte
}

type MetadataReq struct {
	BaseReq
	Topics                             []*MetadataTopicReq
	AllowAutoTopicCreation             bool
	IncludeClusterAuthorizedOperations bool
	IncludeTopicAuthorizedOperations   bool
}

type MetadataResp struct {
	BaseResp
	ThrottleTime               int
	ErrorCode                  int16
	BrokerMetadataList         []*BrokerMetadata
	ClusterId                  string
	ControllerId               int32
	TopicMetadataList          []*TopicMetadata
	ClusterAuthorizedOperation int
}

type MetadataTopicReq struct {
	Topic string
}

type OffsetCommitPartitionReq struct {
	PartitionId int
	Offset      int64
	LeaderEpoch int32
	Metadata    string
}

type OffsetCommitPartitionResp struct {
	PartitionId int
	ErrorCode   ErrorCode
}

type OffsetCommitReq struct {
	BaseReq
	GroupId         string
	GenerationId    int
	MemberId        string
	RetentionTime   int64
	GroupInstanceId *string
	TopicReqList    []*OffsetCommitTopicReq
}

type OffsetCommitResp struct {
	BaseResp
	ThrottleTime  int
	TopicRespList []*OffsetCommitTopicResp
}

type OffsetCommitTopicReq struct {
	Topic            string
	PartitionReqList []*OffsetCommitPartitionReq
}

type OffsetCommitTopicResp struct {
	Topic             string
	PartitionRespList []*OffsetCommitPartitionResp
}

type OffsetFetchPartitionReq struct {
	PartitionId int
}

type OffsetFetchPartitionResp struct {
	PartitionId int
	Offset      int64
	LeaderEpoch int32
	Metadata    *string
	ErrorCode   ErrorCode
}

type OffsetFetchReq struct {
	BaseReq
	GroupId             string
	TopicReqList        []*OffsetFetchTopicReq
	RequireStableOffset bool
}

type OffsetFetchResp struct {
	BaseResp
	ThrottleTime  int
	ErrorCode     ErrorCode
	TopicRespList []*OffsetFetchTopicResp
}

type OffsetFetchTopicReq struct {
	Topic            string
	PartitionReqList []*OffsetFetchPartitionReq
}

type OffsetFetchTopicResp struct {
	Topic             string
	PartitionRespList []*OffsetFetchPartitionResp
}

type OffsetForLeaderEpochPartitionResp struct {
	ErrorCode   ErrorCode
	PartitionId int
	LeaderEpoch int32
	Offset      int64
}

type OffsetForLeaderEpochReq struct {
	BaseReq
	ReplicaId    int32
	TopicReqList []*OffsetLeaderEpochTopicReq
}

type OffsetForLeaderEpochResp struct {
	BaseResp
	ThrottleTime  int
	TopicRespList []*OffsetForLeaderEpochTopicResp
}

type OffsetForLeaderEpochTopicResp struct {
	Topic             string
	PartitionRespList []*OffsetForLeaderEpochPartitionResp
}

type OffsetLeaderEpochPartitionReq struct {
	PartitionId        int
	CurrentLeaderEpoch int32
	LeaderEpoch        int32
}

type OffsetLeaderEpochTopicReq struct {
	Topic            string
	PartitionReqList []*OffsetLeaderEpochPartitionReq
}

type PartitionMetadata struct {
	ErrorCode       ErrorCode
	PartitionId     int
	LeaderId        int32
	LeaderEpoch     int32
	Replicas        []*Replica
	CaughtReplicas  []*Replica
	OfflineReplicas []*Replica
}

type ProducePartitionReq struct {
	PartitionId int
	RecordBatch *RecordBatch
}

type ProducePartitionResp struct {
	PartitionId     int
	ErrorCode       ErrorCode
	Offset          int64
	Time            int64
	LogStartOffset  int64
	RecordErrorList []*RecordError
	ErrorMessage    *string
}

type ProduceReq struct {
	BaseReq
	ClientId      string
	TransactionId *string
	RequiredAcks  int16
	Timeout       int
	TopicReqList  []*ProduceTopicReq
}

type ProduceResp struct {
	BaseResp
	TopicRespList []*ProduceTopicResp
	ThrottleTime  int
}

type ProduceTopicReq struct {
	Topic            string
	PartitionReqList []*ProducePartitionReq
}

type ProduceTopicResp struct {
	Topic             string
	PartitionRespList []*ProducePartitionResp
}

type Record struct {
	RecordAttributes  byte
	RelativeTimestamp int64
	RelativeOffset    int
	Key               []byte
	Value             []byte
	Headers           []*Header
}

type RecordBatch struct {
	Offset      int64
	MessageSize int
	LeaderEpoch int32
	MagicByte   byte
	Flags       uint16

	LastOffsetDelta int
	FirstTimestamp  int64
	LastTimestamp   int64
	ProducerId      int64
	ProducerEpoch   int16
	BaseSequence    int32
	Records         []*Record
}

type RecordError struct {
	BatchIndex             int32
	BatchIndexErrorMessage *string
}

type Replica struct {
	ReplicaId int32
}

type SaslAuthenticateReq struct {
	BaseReq
	Username string
	Password string
}

type SaslAuthenticateResp struct {
	BaseResp
	ErrorCode       ErrorCode
	ErrorMessage    string
	AuthBytes       []byte
	SessionLifetime int64
}

type SaslHandshakeReq struct {
	BaseReq
	SaslMechanism string
}

type SaslHandshakeResp struct {
	BaseResp
	ErrorCode        ErrorCode
	EnableMechanisms []*EnableMechanism
}

type SyncGroupReq struct {
	BaseReq
	GroupId          string
	GenerationId     int
	MemberId         string
	GroupInstanceId  *string
	ProtocolType     string
	ProtocolName     string
	GroupAssignments []*GroupAssignment
}

type SyncGroupResp struct {
	BaseResp
	ThrottleTime     int
	ErrorCode        ErrorCode
	ProtocolType     string
	ProtocolName     string
	MemberAssignment []byte
}

type TopicMetadata struct {
	ErrorCode                ErrorCode
	Topic                    string
	IsInternal               bool
	PartitionMetadataList    []*PartitionMetadata
	TopicAuthorizedOperation int
}