codec

type ApiReq struct {
	BaseReq
	ClientSoftwareName    string
	ClientSoftwareVersion string
}

type ApiRespVersion struct {
	ApiKey     api.Code
	MinVersion int16
	MaxVersion int16
}

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

type BaseReq struct {
	CorrelationId int
	ClientId      string
}

type BaseResp struct {
	CorrelationId int
}

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

type EnableMechanism struct {
	SaslMechanism string
}

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

type FetchPartitionResp struct {
	PartitionIndex      int
	ErrorCode           int16
	HighWatermark       int64
	LastStableOffset    int64
	LogStartOffset      int64
	AbortedTransactions int64
	ReplicaData         int64
	RecordBatch         *RecordBatch
}

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

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

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

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

type FindCoordinatorReq struct {
	BaseReq
	Key     string
	KeyType byte
}

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

type GroupAssignment struct {
	MemberId string
	// COMPACT_BYTES
	MemberAssignment string
}

type GroupProtocol struct {
	ProtocolName     string
	ProtocolMetadata string
}

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

type HeartBeatResp struct {
	BaseResp
	ErrorCode    int16
	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    int16
	ThrottleTime int
	GenerationId int
	ProtocolType *string
	ProtocolName string
	LeaderId     string
	MemberId     string
	Members      []*Member
}

type KafkaProtocolConfig struct {
	ClusterId     string
	AdvertiseHost string
	AdvertisePort int
	NeedSasl      bool
	MaxConn       int32
}

type LeaveGroupMember struct {
	MemberId        string
	GroupInstanceId *string
}

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

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

type ListOffsetPartition struct {
	PartitionId int
	LeaderEpoch int
	Time        int64
}

type ListOffsetPartitionResp struct {
	PartitionId int
	ErrorCode   int16
	Timestamp   int64
	Offset      int64
	LeaderEpoch int
}

type ListOffsetReq struct {
	BaseReq
	ReplicaId      int32
	IsolationLevel byte
	OffsetTopics   []*ListOffsetTopic
}

type ListOffsetResp struct {
	BaseResp
	ErrorCode    int16
	ThrottleTime int
	OffsetTopics []*ListOffsetTopicResp
}

type ListOffsetTopic struct {
	Topic                string
	ListOffsetPartitions []*ListOffsetPartition
}

type ListOffsetTopicResp struct {
	Topic                string
	ListOffsetPartitions []*ListOffsetPartitionResp
}

type Member struct {
	MemberId        string
	GroupInstanceId *string
	Metadata        string
}

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               int
	TopicMetadataList          []*TopicMetadata
	ClusterAuthorizedOperation int
}

type MetadataTopicReq struct {
	Topic string
}

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

type OffsetCommitPartitionResp struct {
	PartitionId int
	ErrorCode   int16
}

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

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

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

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

type OffsetFetchPartitionReq struct {
	PartitionId int
}

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

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

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

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

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

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

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

type RecordBatch struct {
	Offset      int64
	MessageSize int
	LeaderEpoch int
	MagicByte   byte
	// 8位flag字节
	Flags uint16

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

type Replica struct {
	ReplicaId int
}

type SaslAuthenticateReq struct {
	BaseReq
	Username string
	Password string
}

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

type SaslHandshakeReq struct {
	BaseReq
	SaslMechanism string
}

type SaslHandshakeResp struct {
	BaseResp
	ErrorCode        int16
	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        int16
	ProtocolType     string
	ProtocolName     string
	MemberAssignment string
}

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