proto

type Broker struct {
	NodeID int32
	Host   string
	Port   int32
}

type CRCMessage struct {
	CRC uint32
	Message
}

type DescribeGroupsRequest []string

type DescribeGroupsResponse []GroupDescription

type ErrorCode int16

type ErrorInPartition struct {
	Partition int32
	ErrorCode
}

type ErrorInTopic struct {
	TopicName         string
	ErrorInPartitions []ErrorInPartition
}

type FetchMessageSetInPartition struct {
	Partition int32
	ErrorCode
	HighwaterMarkOffset int64
	MessageSet
}

type FetchMessageSetInTopic struct {
	TopicName                   string
	FetchMessageSetInPartitions []FetchMessageSetInPartition
}

type FetchOffsetInPartition struct {
	Partition   int32
	FetchOffset int64
	MaxBytes    int32
}

type FetchOffsetInTopic struct {
	TopicName               string
	FetchOffsetInPartitions []FetchOffsetInPartition
}

type FetchRequest struct {
	ReplicaID           int32
	MaxWaitTime         int32
	MinBytes            int32
	FetchOffsetInTopics []FetchOffsetInTopic
}

type FetchResponse []FetchMessageSetInTopic

type GetTimeFunc func([]byte) (time.Time, error)

type Group struct {
	GroupID      string
	ProtocolType string
}

type GroupAssignment struct {
	MemberID string
	MemberAssignment
}

type GroupAssignments []GroupAssignment

type GroupCoordinator string

type GroupCoordinatorRequest string

type GroupCoordinatorResponse struct {
	ErrorCode
	Broker
}

type GroupDescription struct {
	ErrorCode
	GroupID      string
	State        string
	ProtocolType string
	Protocol     string
	Members
}

type GroupProtocol struct {
	ProtocolName string
	ProtocolMetadata
}

type GroupProtocols []GroupProtocol

type Groups []Group

type HeartbeatRequest struct {
	GroupID      string
	GenerationID int32
	MemberID     string
}

type HeartbeatResponse ErrorCode

type JoinGroupRequest struct {
	GroupID        string
	SessionTimeout int32
	MemberID       string
	ProtocolType   string
	GroupProtocols
}

type JoinGroupResponse struct {
	ErrorCode
	GenerationID      int32
	GroupProtocolName string
	LeaderID          string
	MemberID          string
	MemberWithMetas
}

type LeaveGroupRequest struct {
	GroupID  string
	MemberID string
}

type LeaveGroupResponse ErrorCode

type ListGroupsRequest struct {
}

type ListGroupsResponse struct {
	ErrorCode
	Groups
}

type Member struct {
	MemberID       string
	ClientID       string
	ClientHost     string
	MemberMetadata []byte
	MemberAssignment
}

type MemberAssignment struct {
	Version int16
	PartitionAssignments
}

type MemberWithMeta struct {
	MemberID       string
	MemberMetadata []byte
}

type MemberWithMetas []MemberWithMeta

type Members []Member

type Message struct {
	MagicByte  int8
	Attributes int8
	Key        []byte
	Value      []byte
}

type MessageSet []OffsetMessage

type MessageSetInPartition struct {
	Partition int32
	MessageSet
}

type MessageSetInTopic struct {
	TopicName              string
	MessageSetInPartitions []MessageSetInPartition
}

type Messages struct {
	Topic       string
	Partition   int32
	Offset      int64
	MinBytes    int
	MaxBytes    int
	MaxWaitTime time.Duration
}

type Metadata string

type Offset struct {
	Topic     string
	Partition int32
	Group     string
	Offset    int64
	Retention time.Duration
}

type OffsetByTime struct {
	Topic     string
	Partition int32
	Time      time.Time
}

type OffsetCommitInPartitionV0 struct {
	Partition int32
	Offset    int64
	Metadata  string
}

type OffsetCommitInPartitionV1 struct {
	Partition int32
	Offset    int64
	TimeStamp int64
	Metadata  string
}

type OffsetCommitInPartitionV2 struct {
	Partition int32
	Offset    int64
	Metadata  string
}

type OffsetCommitInTopicV0 struct {
	TopicName                  string
	OffsetCommitInPartitionV0s []OffsetCommitInPartitionV0
}

type OffsetCommitInTopicV1 struct {
	TopicName                  string
	OffsetCommitInPartitionV1s []OffsetCommitInPartitionV1
}

type OffsetCommitInTopicV2 struct {
	TopicName                  string
	OffsetCommitInPartitionV2s []OffsetCommitInPartitionV2
}

type OffsetCommitRequestV0 struct {
	ConsumerGroupID        string
	OffsetCommitInTopicV0s []OffsetCommitInTopicV0
}

type OffsetCommitRequestV1 struct {
	ConsumerGroupID           string
	ConsumerGroupGenerationID int32
	ConsumerID                string
	OffsetCommitInTopicV1s    []OffsetCommitInTopicV1
}

type OffsetCommitRequestV2 struct {
	ConsumerGroup             string
	ConsumerGroupGenerationID int32
	ConsumerID                string
	RetentionTime             int64
	OffsetCommitInTopicV2s    []OffsetCommitInTopicV2
}

type OffsetCommitResponse []ErrorInTopic

type OffsetFetchRequestV0 struct {
	ConsumerGroup     string
	PartitionInTopics []PartitionInTopic
}

type OffsetFetchRequestV1 struct {
	ConsumerGroup     string
	PartitionInTopics []PartitionInTopic
}

type OffsetFetchResponse []OffsetMetadataInTopic

type OffsetInPartition struct {
	Partition int32
	ErrorCode
	Offset int64
}

type OffsetInTopic struct {
	TopicName          string
	OffsetInPartitions []OffsetInPartition
}

type OffsetMessage struct {
	Offset int64
	SizedMessage
}

type OffsetMetadataInPartition struct {
	Partition int32
	Offset    int64
	Metadata  string
	ErrorCode
}

type OffsetMetadataInTopic struct {
	TopicName                  string
	OffsetMetadataInPartitions []OffsetMetadataInPartition
}

type OffsetRequest struct {
	ReplicaID    int32
	TimeInTopics []TimeInTopic
}

type OffsetResponse []OffsetsInTopic

type OffsetsInPartition struct {
	Partition int32
	ErrorCode
	Offsets []int64
}

type OffsetsInTopic struct {
	TopicName           string
	OffsetsInPartitions []OffsetsInPartition
}

type PartitionAssignment struct {
	Topic      string
	Partitions []int32
}

type PartitionAssignments []PartitionAssignment

type PartitionInTopic struct {
	TopicName  string
	Partitions []int32
}

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

type Payload struct {
	Topic        string
	Partition    int32
	MessageSet   MessageSet
	RequiredAcks ProduceAckType
	AckTimeout   time.Duration
}

type ProduceAckType int16

type ProduceRequest struct {
	RequiredAcks       int16
	Timeout            int32
	MessageSetInTopics []MessageSetInTopic
}

type ProduceResponse []OffsetInTopic

type ProtocolMetadata struct {
	Version int16
	Subscription
	UserData []byte
}

type Request struct {
	APIKey        int16
	APIVersion    int16
	CorrelationID int32
	ClientID      string
	RequestMessage
}

type RequestMessage interface {
	wipro.M
	APIKey() int16
	APIVersion() int16
}

type RequestOrResponse struct {
	Size int32
	wipro.M
}

type Response struct {
	CorrelationID int32
	ResponseMessage
}

type ResponseMessage wipro.M

type SizedMessage struct {
	Size int32
	CRCMessage
}

type Subscription []string

type SyncGroupRequest struct {
	GroupID      string
	GenerationID int32
	MemberID     string
	GroupAssignments
}

type SyncGroupResponse struct {
	ErrorCode
	MemberAssignment
}

type TimeInPartition struct {
	Partition          int32
	Time               int64
	MaxNumberOfOffsets int32
}

type TimeInTopic struct {
	TopicName        string
	TimeInPartitions []TimeInPartition
}

type TopicMetadata struct {
	ErrorCode
	TopicName          string
	PartitionMetadatas []PartitionMetadata
}

type TopicMetadataRequest []string

type TopicMetadataResponse struct {
	Brokers        []Broker
	TopicMetadatas []TopicMetadata
}