protocol

type AlterConfigsRequest struct {
	Resources    []AlterConfigsResource
	ValidateOnly bool
}

type AlterConfigsResource struct {
	ResourceType int8
	ResourceName string
	Configs      []AlterConfigsResourceConfig
}

type AlterConfigsResourceConfig struct {
	Name  string
	Value *string
}

type AlterConfigsResponse struct {
	CorrelationID int32
	ThrottleMs    int32
	Resources     []AlterConfigsResponseResource
}

type AlterConfigsResponseResource struct {
	ErrorCode    int16
	ErrorMessage *string
	ResourceType int8
	ResourceName string
}

type ApiVersion struct {
	APIKey     int16
	MinVersion int16
	MaxVersion int16
}

type ApiVersionsRequest struct {
	ClientSoftwareName    string
	ClientSoftwareVersion string
}

type ApiVersionsResponse struct {
	CorrelationID int32
	ErrorCode     int16
	ThrottleMs    int32
	Versions      []ApiVersion
}

type CreatePartitionsAssignment struct {
	Replicas []int32
}

type CreatePartitionsRequest struct {
	Topics       []CreatePartitionsTopic
	TimeoutMs    int32
	ValidateOnly bool
}

type CreatePartitionsResponse struct {
	CorrelationID int32
	ThrottleMs    int32
	Topics        []CreatePartitionsResponseTopic
}

type CreatePartitionsResponseTopic struct {
	Name         string
	ErrorCode    int16
	ErrorMessage *string
}

type CreatePartitionsTopic struct {
	Name        string
	Count       int32
	Assignments []CreatePartitionsAssignment
}

type CreateTopicConfig struct {
	Name              string
	NumPartitions     int32
	ReplicationFactor int16
}

type CreateTopicResult struct {
	Name         string
	ErrorCode    int16
	ErrorMessage string
}

type CreateTopicsRequest struct {
	Topics       []CreateTopicConfig
	TimeoutMs    int32
	ValidateOnly bool
}

type CreateTopicsResponse struct {
	CorrelationID int32
	ThrottleMs    int32
	Topics        []CreateTopicResult
}

type DeleteGroupsRequest struct {
	Groups []string
}

type DeleteGroupsResponse struct {
	CorrelationID int32
	ThrottleMs    int32
	Groups        []DeleteGroupsResponseGroup
}

type DeleteGroupsResponseGroup struct {
	Group     string
	ErrorCode int16
}

type DeleteTopicResult struct {
	Name         string
	ErrorCode    int16
	ErrorMessage string
}

type DeleteTopicsRequest struct {
	TopicNames []string
	TimeoutMs  int32
}

type DeleteTopicsResponse struct {
	CorrelationID int32
	ThrottleMs    int32
	Topics        []DeleteTopicResult
}

type DescribeConfigsRequest struct {
	Resources            []DescribeConfigsResource
	IncludeSynonyms      bool
	IncludeDocumentation bool
}

type DescribeConfigsResource struct {
	ResourceType int8
	ResourceName string
	ConfigNames  []string
}

type DescribeConfigsResponse struct {
	CorrelationID int32
	ThrottleMs    int32
	Resources     []DescribeConfigsResponseResource
}

type DescribeConfigsResponseConfig struct {
	Name          string
	Value         *string
	ReadOnly      bool
	IsDefault     bool
	Source        int8
	IsSensitive   bool
	Synonyms      []DescribeConfigsResponseConfigSynonym
	ConfigType    int8
	Documentation *string
}

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

type DescribeConfigsResponseResource struct {
	ErrorCode    int16
	ErrorMessage *string
	ResourceType int8
	ResourceName string
	Configs      []DescribeConfigsResponseConfig
}

type DescribeGroupsRequest struct {
	Groups                      []string
	IncludeAuthorizedOperations bool
}

type DescribeGroupsResponse struct {
	CorrelationID int32
	ThrottleMs    int32
	Groups        []DescribeGroupsResponseGroup
}

type DescribeGroupsResponseGroup struct {
	ErrorCode            int16
	GroupID              string
	State                string
	ProtocolType         string
	Protocol             string
	Members              []DescribeGroupsResponseGroupMember
	AuthorizedOperations int32
}

type DescribeGroupsResponseGroupMember struct {
	MemberID         string
	InstanceID       *string
	ClientID         string
	ClientHost       string
	ProtocolMetadata []byte
	MemberAssignment []byte
}

type FetchAbortedTransaction struct {
	ProducerID  int64
	FirstOffset int64
}

type FetchPartitionRequest struct {
	Partition   int32
	FetchOffset int64
	MaxBytes    int32
}

type FetchPartitionResponse struct {
	Partition            int32
	ErrorCode            int16
	HighWatermark        int64
	LastStableOffset     int64
	LogStartOffset       int64
	PreferredReadReplica int32
	RecordSet            []byte
	AbortedTransactions  []FetchAbortedTransaction
}

type FetchRequest struct {
	ReplicaID      int32
	MaxWaitMs      int32
	MinBytes       int32
	MaxBytes       int32
	IsolationLevel int8
	SessionID      int32
	SessionEpoch   int32
	Topics         []FetchTopicRequest
}

type FetchResponse struct {
	CorrelationID int32
	ThrottleMs    int32
	ErrorCode     int16
	SessionID     int32
	Topics        []FetchTopicResponse
}

type FetchTopicRequest struct {
	Name       string
	TopicID    [16]byte
	Partitions []FetchPartitionRequest
}

type FetchTopicResponse struct {
	Name       string
	TopicID    [16]byte
	Partitions []FetchPartitionResponse
}

type FindCoordinatorRequest struct {
	KeyType int8
	Key     string
}

type FindCoordinatorResponse struct {
	CorrelationID int32
	ThrottleMs    int32
	ErrorCode     int16
	ErrorMessage  *string
	NodeID        int32
	Host          string
	Port          int32
}

type Frame struct {
	Length  int32
	Payload []byte
}

type HeartbeatRequest struct {
	GroupID      string
	GenerationID int32
	MemberID     string
	InstanceID   *string
}

type HeartbeatResponse struct {
	CorrelationID int32
	ThrottleMs    int32
	ErrorCode     int16
}

type JoinGroupMember struct {
	MemberID   string
	InstanceID *string
	Metadata   []byte
}

type JoinGroupProtocol struct {
	Name     string
	Metadata []byte
}

type JoinGroupRequest struct {
	GroupID            string
	SessionTimeoutMs   int32
	RebalanceTimeoutMs int32
	MemberID           string
	ProtocolType       string
	Protocols          []JoinGroupProtocol
}

type JoinGroupResponse struct {
	CorrelationID int32
	ThrottleMs    int32
	ErrorCode     int16
	GenerationID  int32
	ProtocolName  string
	LeaderID      string
	MemberID      string
	Members       []JoinGroupMember
}

type LeaveGroupRequest struct {
	GroupID  string
	MemberID string
}

type LeaveGroupResponse struct {
	CorrelationID int32
	ErrorCode     int16
}

type ListGroupsRequest struct {
	StatesFilter []string
	TypesFilter  []string
}

type ListGroupsResponse struct {
	CorrelationID int32
	ThrottleMs    int32
	ErrorCode     int16
	Groups        []ListGroupsResponseGroup
}

type ListGroupsResponseGroup struct {
	GroupID      string
	ProtocolType string
	GroupState   string
	GroupType    string
}

type ListOffsetsPartition struct {
	Partition          int32
	Timestamp          int64
	MaxNumOffsets      int32
	CurrentLeaderEpoch int32
}

type ListOffsetsPartitionResponse struct {
	Partition       int32
	ErrorCode       int16
	Timestamp       int64
	Offset          int64
	LeaderEpoch     int32
	OldStyleOffsets []int64
}

type ListOffsetsRequest struct {
	ReplicaID      int32
	IsolationLevel int8
	Topics         []ListOffsetsTopic
}

type ListOffsetsResponse struct {
	CorrelationID int32
	ThrottleMs    int32
	Topics        []ListOffsetsTopicResponse
}

type ListOffsetsTopic struct {
	Name       string
	Partitions []ListOffsetsPartition
}

type ListOffsetsTopicResponse struct {
	Name       string
	Partitions []ListOffsetsPartitionResponse
}

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

type MetadataPartition struct {
	ErrorCode       int16
	PartitionIndex  int32
	LeaderID        int32
	LeaderEpoch     int32
	ReplicaNodes    []int32
	ISRNodes        []int32
	OfflineReplicas []int32
}

type MetadataRequest struct {
	Topics                 []string
	TopicIDs               [][16]byte
	AllowAutoTopicCreation bool
	IncludeClusterAuthOps  bool
	IncludeTopicAuthOps    bool
}

type MetadataResponse struct {
	CorrelationID               int32
	ThrottleMs                  int32
	Brokers                     []MetadataBroker
	ClusterID                   *string
	ControllerID                int32
	Topics                      []MetadataTopic
	ClusterAuthorizedOperations int32
}

type MetadataTopic struct {
	ErrorCode                 int16
	Name                      string
	TopicID                   [16]byte
	IsInternal                bool
	Partitions                []MetadataPartition
	TopicAuthorizedOperations int32
}

type OffsetCommitPartition struct {
	Partition int32
	Offset    int64
	Metadata  string
}

type OffsetCommitPartitionResponse struct {
	Partition int32
	ErrorCode int16
}

type OffsetCommitRequest struct {
	GroupID      string
	GenerationID int32
	MemberID     string
	RetentionMs  int64
	Topics       []OffsetCommitTopic
}

type OffsetCommitResponse struct {
	CorrelationID int32
	ThrottleMs    int32
	Topics        []OffsetCommitTopicResponse
}

type OffsetCommitTopic struct {
	Name       string
	Partitions []OffsetCommitPartition
}

type OffsetCommitTopicResponse struct {
	Name       string
	Partitions []OffsetCommitPartitionResponse
}

type OffsetFetchPartition struct {
	Partition int32
}

type OffsetFetchPartitionResponse struct {
	Partition   int32
	Offset      int64
	LeaderEpoch int32
	Metadata    *string
	ErrorCode   int16
}

type OffsetFetchRequest struct {
	GroupID string
	Topics  []OffsetFetchTopic
}

type OffsetFetchResponse struct {
	CorrelationID int32
	ThrottleMs    int32
	Topics        []OffsetFetchTopicResponse
	ErrorCode     int16
}

type OffsetFetchTopic struct {
	Name       string
	Partitions []OffsetFetchPartition
}

type OffsetFetchTopicResponse struct {
	Name       string
	Partitions []OffsetFetchPartitionResponse
}

type OffsetForLeaderEpochPartition struct {
	Partition          int32
	CurrentLeaderEpoch int32
	LeaderEpoch        int32
}

type OffsetForLeaderEpochPartitionResponse struct {
	Partition   int32
	ErrorCode   int16
	LeaderEpoch int32
	EndOffset   int64
}

type OffsetForLeaderEpochRequest struct {
	ReplicaID int32
	Topics    []OffsetForLeaderEpochTopic
}

type OffsetForLeaderEpochResponse struct {
	CorrelationID int32
	ThrottleMs    int32
	Topics        []OffsetForLeaderEpochTopicResponse
}

type OffsetForLeaderEpochTopic struct {
	Name       string
	Partitions []OffsetForLeaderEpochPartition
}

type OffsetForLeaderEpochTopicResponse struct {
	Name       string
	Partitions []OffsetForLeaderEpochPartitionResponse
}

type ProducePartition struct {
	Partition int32
	Records   []byte
}

type ProducePartitionResponse struct {
	Partition       int32
	ErrorCode       int16
	BaseOffset      int64
	LogAppendTimeMs int64
	LogStartOffset  int64
}

type ProduceRequest struct {
	Acks            int16
	TimeoutMs       int32
	TransactionalID *string
	Topics          []ProduceTopic
}

type ProduceResponse struct {
	CorrelationID int32
	Topics        []ProduceTopicResponse
	ThrottleMs    int32
}

type ProduceTopic struct {
	Name       string
	Partitions []ProducePartition
}

type ProduceTopicResponse struct {
	Name       string
	Partitions []ProducePartitionResponse
}

type Request interface {
	APIKey() int16
}

type RequestHeader struct {
	APIKey        int16
	APIVersion    int16
	CorrelationID int32
	ClientID      *string
}

type SyncGroupAssignment struct {
	MemberID   string
	Assignment []byte
}

type SyncGroupRequest struct {
	GroupID      string
	GenerationID int32
	MemberID     string
	Assignments  []SyncGroupAssignment
}

type SyncGroupResponse struct {
	CorrelationID int32
	ThrottleMs    int32
	ErrorCode     int16
	ProtocolType  *string
	ProtocolName  *string
	Assignment    []byte
}