kmsg

package module

Go to main page

Versions in this module

v1

v1.8.0

May 9, 2024

Changes in this version

+ type ConsumerGroupHeartbeatRequest struct

+ Group string

+ InstanceID *string

+ MemberEpoch int32

+ MemberID string

+ RackID *string

+ RebalanceTimeoutMillis int32

+ ServerAssignor *string

+ SubscribedTopicNames []string

+ Topics []ConsumerGroupHeartbeatRequestTopic

+ UnknownTags Tags

+ Version int16

+ func NewConsumerGroupHeartbeatRequest() ConsumerGroupHeartbeatRequest

+ func NewPtrConsumerGroupHeartbeatRequest() *ConsumerGroupHeartbeatRequest

+ func (*ConsumerGroupHeartbeatRequest) Key() int16

+ func (*ConsumerGroupHeartbeatRequest) MaxVersion() int16

+ func (v *ConsumerGroupHeartbeatRequest) AppendTo(dst []byte) []byte

+ func (v *ConsumerGroupHeartbeatRequest) Default()

+ func (v *ConsumerGroupHeartbeatRequest) GetVersion() int16

+ func (v *ConsumerGroupHeartbeatRequest) IsFlexible() bool

+ func (v *ConsumerGroupHeartbeatRequest) ReadFrom(src []byte) error

+ func (v *ConsumerGroupHeartbeatRequest) RequestWith(ctx context.Context, r Requestor) (*ConsumerGroupHeartbeatResponse, error)

+ func (v *ConsumerGroupHeartbeatRequest) ResponseKind() Response

+ func (v *ConsumerGroupHeartbeatRequest) SetVersion(version int16)

+ func (v *ConsumerGroupHeartbeatRequest) UnsafeReadFrom(src []byte) error

+ type ConsumerGroupHeartbeatRequestTopic struct

+ Partitions []int32

+ TopicID [16]byte

+ UnknownTags Tags

+ func NewConsumerGroupHeartbeatRequestTopic() ConsumerGroupHeartbeatRequestTopic

+ func (v *ConsumerGroupHeartbeatRequestTopic) Default()

+ type ConsumerGroupHeartbeatResponse struct

+ Assignment *ConsumerGroupHeartbeatResponseAssignment

+ ErrorCode int16

+ ErrorMessage *string

+ HeartbeatIntervalMillis int32

+ MemberEpoch int32

+ MemberID *string

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewConsumerGroupHeartbeatResponse() ConsumerGroupHeartbeatResponse

+ func NewPtrConsumerGroupHeartbeatResponse() *ConsumerGroupHeartbeatResponse

+ func (*ConsumerGroupHeartbeatResponse) Key() int16

+ func (*ConsumerGroupHeartbeatResponse) MaxVersion() int16

+ func (v *ConsumerGroupHeartbeatResponse) AppendTo(dst []byte) []byte

+ func (v *ConsumerGroupHeartbeatResponse) Default()

+ func (v *ConsumerGroupHeartbeatResponse) GetVersion() int16

+ func (v *ConsumerGroupHeartbeatResponse) IsFlexible() bool

+ func (v *ConsumerGroupHeartbeatResponse) ReadFrom(src []byte) error

+ func (v *ConsumerGroupHeartbeatResponse) RequestKind() Request

+ func (v *ConsumerGroupHeartbeatResponse) SetThrottle(throttleMillis int32)

+ func (v *ConsumerGroupHeartbeatResponse) SetVersion(version int16)

+ func (v *ConsumerGroupHeartbeatResponse) Throttle() (int32, bool)

+ func (v *ConsumerGroupHeartbeatResponse) UnsafeReadFrom(src []byte) error

+ type ConsumerGroupHeartbeatResponseAssignment struct

+ Topics []ConsumerGroupHeartbeatResponseAssignmentTopic

+ UnknownTags Tags

+ func NewConsumerGroupHeartbeatResponseAssignment() ConsumerGroupHeartbeatResponseAssignment

+ func (v *ConsumerGroupHeartbeatResponseAssignment) Default()

+ type ConsumerGroupHeartbeatResponseAssignmentTopic struct

+ Partitions []int32

+ TopicID [16]byte

+ UnknownTags Tags

+ func NewConsumerGroupHeartbeatResponseAssignmentTopic() ConsumerGroupHeartbeatResponseAssignmentTopic

+ func (v *ConsumerGroupHeartbeatResponseAssignmentTopic) Default()

type DescribeClusterRequest

+ EndpointType int8

type DescribeClusterResponse

+ EndpointType int8

type FetchResponse

+ Brokers []FetchResponseBroker

+ type FetchResponseBroker struct

+ Host string

+ NodeID int32

+ Port int32

+ Rack *string

+ UnknownTags Tags

+ func NewFetchResponseBroker() FetchResponseBroker

+ func (v *FetchResponseBroker) Default()

type Key

+ const ConsumerGroupHeartbeat

type OffsetFetchRequestGroup

+ MemberEpoch int32

+ MemberID *string

type ProduceResponse

+ Brokers []ProduceResponseBroker

+ type ProduceResponseBroker struct

+ Host string

+ NodeID int32

+ Port int32

+ Rack *string

+ UnknownTags Tags

+ func NewProduceResponseBroker() ProduceResponseBroker

+ func (v *ProduceResponseBroker) Default()

type ProduceResponseTopicPartition

+ CurrentLeader ProduceResponseTopicPartitionCurrentLeader

+ type ProduceResponseTopicPartitionCurrentLeader struct

+ LeaderEpoch int32

+ LeaderID int32

+ UnknownTags Tags

+ func NewProduceResponseTopicPartitionCurrentLeader() ProduceResponseTopicPartitionCurrentLeader

+ func (v *ProduceResponseTopicPartitionCurrentLeader) Default()

v1.7.0

Oct 21, 2023

Changes in this version

type AddPartitionsToTxnRequest

+ Transactions []AddPartitionsToTxnRequestTransaction

+ type AddPartitionsToTxnRequestTransaction struct

+ ProducerEpoch int16

+ ProducerID int64

+ Topics []AddPartitionsToTxnRequestTransactionTopic

+ TransactionalID string

+ UnknownTags Tags

+ VerifyOnly bool

+ func NewAddPartitionsToTxnRequestTransaction() AddPartitionsToTxnRequestTransaction

+ func (v *AddPartitionsToTxnRequestTransaction) Default()

+ type AddPartitionsToTxnRequestTransactionTopic struct

+ Partitions []int32

+ Topic string

+ UnknownTags Tags

+ func NewAddPartitionsToTxnRequestTransactionTopic() AddPartitionsToTxnRequestTransactionTopic

+ func (v *AddPartitionsToTxnRequestTransactionTopic) Default()

type AddPartitionsToTxnResponse

+ ErrorCode int16

+ Transactions []AddPartitionsToTxnResponseTransaction

+ type AddPartitionsToTxnResponseTransaction struct

+ Topics []AddPartitionsToTxnResponseTransactionTopic

+ TransactionalID string

+ UnknownTags Tags

+ func NewAddPartitionsToTxnResponseTransaction() AddPartitionsToTxnResponseTransaction

+ func (v *AddPartitionsToTxnResponseTransaction) Default()

+ type AddPartitionsToTxnResponseTransactionTopic struct

+ Partitions []AddPartitionsToTxnResponseTransactionTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewAddPartitionsToTxnResponseTransactionTopic() AddPartitionsToTxnResponseTransactionTopic

+ func (v *AddPartitionsToTxnResponseTransactionTopic) Default()

+ type AddPartitionsToTxnResponseTransactionTopicPartition struct

+ ErrorCode int16

+ Partition int32

+ UnknownTags Tags

+ func NewAddPartitionsToTxnResponseTransactionTopicPartition() AddPartitionsToTxnResponseTransactionTopicPartition

+ func (v *AddPartitionsToTxnResponseTransactionTopicPartition) Default()

v1.6.1

Jul 8, 2023

v1.6.0

Jul 8, 2023

Changes in this version

type AlterPartitionRequestTopicPartition

+ NewEpochISR []AlterPartitionRequestTopicPartitionNewEpochISR

+ type AlterPartitionRequestTopicPartitionNewEpochISR struct

+ BrokerEpoch int32

+ BrokerID int32

+ UnknownTags Tags

+ func NewAlterPartitionRequestTopicPartitionNewEpochISR() AlterPartitionRequestTopicPartitionNewEpochISR

+ func (v *AlterPartitionRequestTopicPartitionNewEpochISR) Default()

type FetchRequest

+ ReplicaState FetchRequestReplicaState

+ type FetchRequestReplicaState struct

+ Epoch int64

+ ID int32

+ UnknownTags Tags

+ func NewFetchRequestReplicaState() FetchRequestReplicaState

+ func (v *FetchRequestReplicaState) Default()

v1.5.0

Mar 25, 2023

Changes in this version

type AddOffsetsToTxnResponse

+ func (v *AddOffsetsToTxnResponse) SetThrottle(throttleMillis int32)

type AddPartitionsToTxnResponse

+ func (v *AddPartitionsToTxnResponse) SetThrottle(throttleMillis int32)

type AllocateProducerIDsResponse

+ func (v *AllocateProducerIDsResponse) SetThrottle(throttleMillis int32)

type AlterClientQuotasResponse

+ func (v *AlterClientQuotasResponse) SetThrottle(throttleMillis int32)

type AlterConfigsResponse

+ func (v *AlterConfigsResponse) SetThrottle(throttleMillis int32)

type AlterPartitionAssignmentsRequest

+ func (v *AlterPartitionAssignmentsRequest) SetTimeout(timeoutMillis int32)

type AlterPartitionAssignmentsResponse

+ func (v *AlterPartitionAssignmentsResponse) SetThrottle(throttleMillis int32)

type AlterPartitionResponse

+ func (v *AlterPartitionResponse) SetThrottle(throttleMillis int32)

type AlterReplicaLogDirsResponse

+ func (v *AlterReplicaLogDirsResponse) SetThrottle(throttleMillis int32)

type AlterUserSCRAMCredentialsResponse

+ func (v *AlterUserSCRAMCredentialsResponse) SetThrottle(throttleMillis int32)

type ApiVersionsResponse

+ func (v *ApiVersionsResponse) SetThrottle(throttleMillis int32)

type BrokerHeartbeatResponse

+ func (v *BrokerHeartbeatResponse) SetThrottle(throttleMillis int32)

type BrokerRegistrationResponse

+ func (v *BrokerRegistrationResponse) SetThrottle(throttleMillis int32)

type CreateACLsResponse

+ func (v *CreateACLsResponse) SetThrottle(throttleMillis int32)

type CreateDelegationTokenResponse

+ func (v *CreateDelegationTokenResponse) SetThrottle(throttleMillis int32)

type CreatePartitionsRequest

+ func (v *CreatePartitionsRequest) SetTimeout(timeoutMillis int32)

type CreatePartitionsResponse

+ func (v *CreatePartitionsResponse) SetThrottle(throttleMillis int32)

type CreateTopicsRequest

+ func (v *CreateTopicsRequest) SetTimeout(timeoutMillis int32)

type CreateTopicsResponse

+ func (v *CreateTopicsResponse) SetThrottle(throttleMillis int32)

type DeleteACLsResponse

+ func (v *DeleteACLsResponse) SetThrottle(throttleMillis int32)

type DeleteGroupsResponse

+ func (v *DeleteGroupsResponse) SetThrottle(throttleMillis int32)

type DeleteRecordsRequest

+ func (v *DeleteRecordsRequest) SetTimeout(timeoutMillis int32)

type DeleteRecordsResponse

+ func (v *DeleteRecordsResponse) SetThrottle(throttleMillis int32)

type DeleteTopicsRequest

+ func (v *DeleteTopicsRequest) SetTimeout(timeoutMillis int32)

type DeleteTopicsResponse

+ func (v *DeleteTopicsResponse) SetThrottle(throttleMillis int32)

type DescribeACLsResponse

+ func (v *DescribeACLsResponse) SetThrottle(throttleMillis int32)

type DescribeClientQuotasResponse

+ func (v *DescribeClientQuotasResponse) SetThrottle(throttleMillis int32)

type DescribeClusterResponse

+ func (v *DescribeClusterResponse) SetThrottle(throttleMillis int32)

type DescribeConfigsResponse

+ func (v *DescribeConfigsResponse) SetThrottle(throttleMillis int32)

type DescribeDelegationTokenResponse

+ func (v *DescribeDelegationTokenResponse) SetThrottle(throttleMillis int32)

type DescribeGroupsResponse

+ func (v *DescribeGroupsResponse) SetThrottle(throttleMillis int32)

type DescribeLogDirsResponse

+ func (v *DescribeLogDirsResponse) SetThrottle(throttleMillis int32)

type DescribeProducersResponse

+ func (v *DescribeProducersResponse) SetThrottle(throttleMillis int32)

type DescribeTransactionsResponse

+ func (v *DescribeTransactionsResponse) SetThrottle(throttleMillis int32)

type DescribeUserSCRAMCredentialsResponse

+ func (v *DescribeUserSCRAMCredentialsResponse) SetThrottle(throttleMillis int32)

type ElectLeadersRequest

+ func (v *ElectLeadersRequest) SetTimeout(timeoutMillis int32)

type ElectLeadersResponse

+ func (v *ElectLeadersResponse) SetThrottle(throttleMillis int32)

type EndTxnResponse

+ func (v *EndTxnResponse) SetThrottle(throttleMillis int32)

type ExpireDelegationTokenResponse

+ func (v *ExpireDelegationTokenResponse) SetThrottle(throttleMillis int32)

type FetchResponse

+ func (v *FetchResponse) SetThrottle(throttleMillis int32)

type FetchSnapshotResponse

+ func (v *FetchSnapshotResponse) SetThrottle(throttleMillis int32)

type FindCoordinatorResponse

+ func (v *FindCoordinatorResponse) SetThrottle(throttleMillis int32)

type HeartbeatResponse

+ func (v *HeartbeatResponse) SetThrottle(throttleMillis int32)

type IncrementalAlterConfigsResponse

+ func (v *IncrementalAlterConfigsResponse) SetThrottle(throttleMillis int32)

type InitProducerIDResponse

+ func (v *InitProducerIDResponse) SetThrottle(throttleMillis int32)

type JoinGroupResponse

+ func (v *JoinGroupResponse) SetThrottle(throttleMillis int32)

type LeaveGroupResponse

+ func (v *LeaveGroupResponse) SetThrottle(throttleMillis int32)

type ListGroupsResponse

+ func (v *ListGroupsResponse) SetThrottle(throttleMillis int32)

type ListOffsetsResponse

+ func (v *ListOffsetsResponse) SetThrottle(throttleMillis int32)

type ListPartitionReassignmentsRequest

+ func (v *ListPartitionReassignmentsRequest) SetTimeout(timeoutMillis int32)

type ListPartitionReassignmentsResponse

+ func (v *ListPartitionReassignmentsResponse) SetThrottle(throttleMillis int32)

type ListTransactionsResponse

+ func (v *ListTransactionsResponse) SetThrottle(throttleMillis int32)

type MetadataResponse

+ func (v *MetadataResponse) SetThrottle(throttleMillis int32)

type OffsetCommitResponse

+ func (v *OffsetCommitResponse) SetThrottle(throttleMillis int32)

type OffsetDeleteResponse

+ func (v *OffsetDeleteResponse) SetThrottle(throttleMillis int32)

type OffsetFetchResponse

+ func (v *OffsetFetchResponse) SetThrottle(throttleMillis int32)

type OffsetForLeaderEpochResponse

+ func (v *OffsetForLeaderEpochResponse) SetThrottle(throttleMillis int32)

type ProduceRequest

+ func (v *ProduceRequest) SetTimeout(timeoutMillis int32)

type ProduceResponse

+ func (v *ProduceResponse) SetThrottle(throttleMillis int32)

type RenewDelegationTokenResponse

+ func (v *RenewDelegationTokenResponse) SetThrottle(throttleMillis int32)

+ type SetThrottleResponse interface

+ SetThrottle func(int32)

+ type SetTimeoutRequest interface

+ SetTimeout func(timeoutMillis int32)

type SyncGroupResponse

+ func (v *SyncGroupResponse) SetThrottle(throttleMillis int32)

type TxnOffsetCommitResponse

+ func (v *TxnOffsetCommitResponse) SetThrottle(throttleMillis int32)

type UnregisterBrokerResponse

+ func (v *UnregisterBrokerResponse) SetThrottle(throttleMillis int32)

type UpdateFeaturesRequest

+ func (v *UpdateFeaturesRequest) SetTimeout(timeoutMillis int32)

type UpdateFeaturesResponse

+ func (v *UpdateFeaturesResponse) SetThrottle(throttleMillis int32)

v1.4.0

Feb 8, 2023

Changes in this version

type ApiVersionsResponse

+ ZkMigrationReady bool

type BrokerRegistrationRequest

+ IsMigratingZkBroker bool

type ConsumerMemberMetadata

+ Generation int32

+ Rack *string

type LeaderAndISRRequest

+ IsKRaftController bool

type StopReplicaRequest

+ IsKRaftController bool

type UpdateMetadataRequest

+ IsKRaftController bool

v1.3.0

Jan 29, 2023

Changes in this version

type Record

+ TimestampDelta64 int64

v1.2.0

Aug 5, 2022

Changes in this version

type ACLOperation

+ const ACLOperationCreateTokens

+ const ACLOperationDescribeTokens

type ACLResourceType

+ const ACLResourceTypeUser

type AlterPartitionRequestTopic

+ TopicID [16]byte

type AlterPartitionResponseTopic

+ TopidID [16]byte

type CreateDelegationTokenRequest

+ OwnerPrincipalName *string

+ OwnerPrincipalType *string

type CreateDelegationTokenResponse

+ TokenRequesterPrincipalName string

+ TokenRequesterPrincipalType string

type DescribeDelegationTokenResponseTokenDetail

+ TokenRequesterPrincipalName string

+ TokenRequesterPrincipalType string

type DescribeLogDirsResponseDir

+ TotalBytes int64

+ UsableBytes int64

type DescribeQuorumResponseTopicPartitionReplicaState

+ LastCaughtUpTimestamp int64

+ LastFetchTimestamp int64

type VoteResponseTopicPartition

+ LeaderEpoch int32

v1.1.0

May 23, 2022

Changes in this version

type AddOffsetsToTxnRequest

+ func (v *AddOffsetsToTxnRequest) UnsafeReadFrom(src []byte) error

type AddOffsetsToTxnResponse

+ func (v *AddOffsetsToTxnResponse) UnsafeReadFrom(src []byte) error

type AddPartitionsToTxnRequest

+ func (v *AddPartitionsToTxnRequest) UnsafeReadFrom(src []byte) error

type AddPartitionsToTxnResponse

+ func (v *AddPartitionsToTxnResponse) UnsafeReadFrom(src []byte) error

type AllocateProducerIDsRequest

+ func (v *AllocateProducerIDsRequest) UnsafeReadFrom(src []byte) error

type AllocateProducerIDsResponse

+ func (v *AllocateProducerIDsResponse) UnsafeReadFrom(src []byte) error

type AlterClientQuotasRequest

+ func (v *AlterClientQuotasRequest) UnsafeReadFrom(src []byte) error

type AlterClientQuotasResponse

+ func (v *AlterClientQuotasResponse) UnsafeReadFrom(src []byte) error

type AlterConfigsRequest

+ func (v *AlterConfigsRequest) UnsafeReadFrom(src []byte) error

type AlterConfigsResponse

+ func (v *AlterConfigsResponse) UnsafeReadFrom(src []byte) error

type AlterPartitionAssignmentsRequest

+ func (v *AlterPartitionAssignmentsRequest) UnsafeReadFrom(src []byte) error

type AlterPartitionAssignmentsResponse

+ func (v *AlterPartitionAssignmentsResponse) UnsafeReadFrom(src []byte) error

type AlterPartitionRequest

+ func (v *AlterPartitionRequest) UnsafeReadFrom(src []byte) error

type AlterPartitionResponse

+ func (v *AlterPartitionResponse) UnsafeReadFrom(src []byte) error

type AlterReplicaLogDirsRequest

+ func (v *AlterReplicaLogDirsRequest) UnsafeReadFrom(src []byte) error

type AlterReplicaLogDirsResponse

+ func (v *AlterReplicaLogDirsResponse) UnsafeReadFrom(src []byte) error

type AlterUserSCRAMCredentialsRequest

+ func (v *AlterUserSCRAMCredentialsRequest) UnsafeReadFrom(src []byte) error

type AlterUserSCRAMCredentialsResponse

+ func (v *AlterUserSCRAMCredentialsResponse) UnsafeReadFrom(src []byte) error

type ApiVersionsRequest

+ func (v *ApiVersionsRequest) UnsafeReadFrom(src []byte) error

type ApiVersionsResponse

+ func (v *ApiVersionsResponse) UnsafeReadFrom(src []byte) error

type BeginQuorumEpochRequest

+ func (v *BeginQuorumEpochRequest) UnsafeReadFrom(src []byte) error

type BeginQuorumEpochResponse

+ func (v *BeginQuorumEpochResponse) UnsafeReadFrom(src []byte) error

type BrokerHeartbeatRequest

+ func (v *BrokerHeartbeatRequest) UnsafeReadFrom(src []byte) error

type BrokerHeartbeatResponse

+ func (v *BrokerHeartbeatResponse) UnsafeReadFrom(src []byte) error

type BrokerRegistrationRequest

+ func (v *BrokerRegistrationRequest) UnsafeReadFrom(src []byte) error

type BrokerRegistrationResponse

+ func (v *BrokerRegistrationResponse) UnsafeReadFrom(src []byte) error

type ConnectMemberAssignment

+ func (v *ConnectMemberAssignment) UnsafeReadFrom(src []byte) error

type ConnectMemberMetadata

+ func (v *ConnectMemberMetadata) UnsafeReadFrom(src []byte) error

type ConsumerMemberAssignment

+ func (v *ConsumerMemberAssignment) UnsafeReadFrom(src []byte) error

type ConsumerMemberMetadata

+ func (v *ConsumerMemberMetadata) UnsafeReadFrom(src []byte) error

type ControlRecordKey

+ func (v *ControlRecordKey) UnsafeReadFrom(src []byte) error

type ControlledShutdownRequest

+ func (v *ControlledShutdownRequest) UnsafeReadFrom(src []byte) error

type ControlledShutdownResponse

+ func (v *ControlledShutdownResponse) UnsafeReadFrom(src []byte) error

type CreateACLsRequest

+ func (v *CreateACLsRequest) UnsafeReadFrom(src []byte) error

type CreateACLsResponse

+ func (v *CreateACLsResponse) UnsafeReadFrom(src []byte) error

type CreateDelegationTokenRequest

+ func (v *CreateDelegationTokenRequest) UnsafeReadFrom(src []byte) error

type CreateDelegationTokenResponse

+ func (v *CreateDelegationTokenResponse) UnsafeReadFrom(src []byte) error

type CreatePartitionsRequest

+ func (v *CreatePartitionsRequest) UnsafeReadFrom(src []byte) error

type CreatePartitionsResponse

+ func (v *CreatePartitionsResponse) UnsafeReadFrom(src []byte) error

type CreateTopicsRequest

+ func (v *CreateTopicsRequest) UnsafeReadFrom(src []byte) error

type CreateTopicsResponse

+ func (v *CreateTopicsResponse) UnsafeReadFrom(src []byte) error

type DefaultPrincipalData

+ func (v *DefaultPrincipalData) UnsafeReadFrom(src []byte) error

type DeleteACLsRequest

+ func (v *DeleteACLsRequest) UnsafeReadFrom(src []byte) error

type DeleteACLsResponse

+ func (v *DeleteACLsResponse) UnsafeReadFrom(src []byte) error

type DeleteGroupsRequest

+ func (v *DeleteGroupsRequest) UnsafeReadFrom(src []byte) error

type DeleteGroupsResponse

+ func (v *DeleteGroupsResponse) UnsafeReadFrom(src []byte) error

type DeleteRecordsRequest

+ func (v *DeleteRecordsRequest) UnsafeReadFrom(src []byte) error

type DeleteRecordsResponse

+ func (v *DeleteRecordsResponse) UnsafeReadFrom(src []byte) error

type DeleteTopicsRequest

+ func (v *DeleteTopicsRequest) UnsafeReadFrom(src []byte) error

type DeleteTopicsResponse

+ func (v *DeleteTopicsResponse) UnsafeReadFrom(src []byte) error

type DescribeACLsRequest

+ func (v *DescribeACLsRequest) UnsafeReadFrom(src []byte) error

type DescribeACLsResponse

+ func (v *DescribeACLsResponse) UnsafeReadFrom(src []byte) error

type DescribeClientQuotasRequest

+ func (v *DescribeClientQuotasRequest) UnsafeReadFrom(src []byte) error

type DescribeClientQuotasResponse

+ func (v *DescribeClientQuotasResponse) UnsafeReadFrom(src []byte) error

type DescribeClusterRequest

+ func (v *DescribeClusterRequest) UnsafeReadFrom(src []byte) error

type DescribeClusterResponse

+ func (v *DescribeClusterResponse) UnsafeReadFrom(src []byte) error

type DescribeConfigsRequest

+ func (v *DescribeConfigsRequest) UnsafeReadFrom(src []byte) error

type DescribeConfigsResponse

+ func (v *DescribeConfigsResponse) UnsafeReadFrom(src []byte) error

type DescribeDelegationTokenRequest

+ func (v *DescribeDelegationTokenRequest) UnsafeReadFrom(src []byte) error

type DescribeDelegationTokenResponse

+ func (v *DescribeDelegationTokenResponse) UnsafeReadFrom(src []byte) error

type DescribeGroupsRequest

+ func (v *DescribeGroupsRequest) UnsafeReadFrom(src []byte) error

type DescribeGroupsResponse

+ func (v *DescribeGroupsResponse) UnsafeReadFrom(src []byte) error

type DescribeLogDirsRequest

+ func (v *DescribeLogDirsRequest) UnsafeReadFrom(src []byte) error

type DescribeLogDirsResponse

+ func (v *DescribeLogDirsResponse) UnsafeReadFrom(src []byte) error

type DescribeProducersRequest

+ func (v *DescribeProducersRequest) UnsafeReadFrom(src []byte) error

type DescribeProducersResponse

+ func (v *DescribeProducersResponse) UnsafeReadFrom(src []byte) error

type DescribeQuorumRequest

+ func (v *DescribeQuorumRequest) UnsafeReadFrom(src []byte) error

type DescribeQuorumResponse

+ func (v *DescribeQuorumResponse) UnsafeReadFrom(src []byte) error

type DescribeTransactionsRequest

+ func (v *DescribeTransactionsRequest) UnsafeReadFrom(src []byte) error

type DescribeTransactionsResponse

+ func (v *DescribeTransactionsResponse) UnsafeReadFrom(src []byte) error

type DescribeUserSCRAMCredentialsRequest

+ func (v *DescribeUserSCRAMCredentialsRequest) UnsafeReadFrom(src []byte) error

type DescribeUserSCRAMCredentialsResponse

+ func (v *DescribeUserSCRAMCredentialsResponse) UnsafeReadFrom(src []byte) error

type ElectLeadersRequest

+ func (v *ElectLeadersRequest) UnsafeReadFrom(src []byte) error

type ElectLeadersResponse

+ func (v *ElectLeadersResponse) UnsafeReadFrom(src []byte) error

type EndQuorumEpochRequest

+ func (v *EndQuorumEpochRequest) UnsafeReadFrom(src []byte) error

type EndQuorumEpochResponse

+ func (v *EndQuorumEpochResponse) UnsafeReadFrom(src []byte) error

type EndTxnMarker

+ func (v *EndTxnMarker) UnsafeReadFrom(src []byte) error

type EndTxnRequest

+ func (v *EndTxnRequest) UnsafeReadFrom(src []byte) error

type EndTxnResponse

+ func (v *EndTxnResponse) UnsafeReadFrom(src []byte) error

type EnvelopeRequest

+ func (v *EnvelopeRequest) UnsafeReadFrom(src []byte) error

type EnvelopeResponse

+ func (v *EnvelopeResponse) UnsafeReadFrom(src []byte) error

type ExpireDelegationTokenRequest

+ func (v *ExpireDelegationTokenRequest) UnsafeReadFrom(src []byte) error

type ExpireDelegationTokenResponse

+ func (v *ExpireDelegationTokenResponse) UnsafeReadFrom(src []byte) error

type FetchRequest

+ func (v *FetchRequest) UnsafeReadFrom(src []byte) error

type FetchResponse

+ func (v *FetchResponse) UnsafeReadFrom(src []byte) error

type FetchSnapshotRequest

+ func (v *FetchSnapshotRequest) UnsafeReadFrom(src []byte) error

type FetchSnapshotResponse

+ func (v *FetchSnapshotResponse) UnsafeReadFrom(src []byte) error

type FindCoordinatorRequest

+ func (v *FindCoordinatorRequest) UnsafeReadFrom(src []byte) error

type FindCoordinatorResponse

+ func (v *FindCoordinatorResponse) UnsafeReadFrom(src []byte) error

type GroupMetadataKey

+ func (v *GroupMetadataKey) UnsafeReadFrom(src []byte) error

type GroupMetadataValue

+ func (v *GroupMetadataValue) UnsafeReadFrom(src []byte) error

type Header

+ func (v *Header) UnsafeReadFrom(src []byte) error

type HeartbeatRequest

+ func (v *HeartbeatRequest) UnsafeReadFrom(src []byte) error

type HeartbeatResponse

+ func (v *HeartbeatResponse) UnsafeReadFrom(src []byte) error

type IncrementalAlterConfigsRequest

+ func (v *IncrementalAlterConfigsRequest) UnsafeReadFrom(src []byte) error

type IncrementalAlterConfigsResponse

+ func (v *IncrementalAlterConfigsResponse) UnsafeReadFrom(src []byte) error

type InitProducerIDRequest

+ func (v *InitProducerIDRequest) UnsafeReadFrom(src []byte) error

type InitProducerIDResponse

+ func (v *InitProducerIDResponse) UnsafeReadFrom(src []byte) error

type JoinGroupRequest

+ func (v *JoinGroupRequest) UnsafeReadFrom(src []byte) error

type JoinGroupResponse

+ func (v *JoinGroupResponse) UnsafeReadFrom(src []byte) error

type LeaderAndISRRequest

+ func (v *LeaderAndISRRequest) UnsafeReadFrom(src []byte) error

type LeaderAndISRResponse

+ func (v *LeaderAndISRResponse) UnsafeReadFrom(src []byte) error

type LeaderChangeMessage

+ func (v *LeaderChangeMessage) UnsafeReadFrom(src []byte) error

type LeaveGroupRequest

+ func (v *LeaveGroupRequest) UnsafeReadFrom(src []byte) error

type LeaveGroupResponse

+ func (v *LeaveGroupResponse) UnsafeReadFrom(src []byte) error

type ListGroupsRequest

+ func (v *ListGroupsRequest) UnsafeReadFrom(src []byte) error

type ListGroupsResponse

+ func (v *ListGroupsResponse) UnsafeReadFrom(src []byte) error

type ListOffsetsRequest

+ func (v *ListOffsetsRequest) UnsafeReadFrom(src []byte) error

type ListOffsetsResponse

+ func (v *ListOffsetsResponse) UnsafeReadFrom(src []byte) error

type ListPartitionReassignmentsRequest

+ func (v *ListPartitionReassignmentsRequest) UnsafeReadFrom(src []byte) error

type ListPartitionReassignmentsResponse

+ func (v *ListPartitionReassignmentsResponse) UnsafeReadFrom(src []byte) error

type ListTransactionsRequest

+ func (v *ListTransactionsRequest) UnsafeReadFrom(src []byte) error

type ListTransactionsResponse

+ func (v *ListTransactionsResponse) UnsafeReadFrom(src []byte) error

type MessageV0

+ func (v *MessageV0) UnsafeReadFrom(src []byte) error

type MessageV1

+ func (v *MessageV1) UnsafeReadFrom(src []byte) error

type MetadataRequest

+ func (v *MetadataRequest) UnsafeReadFrom(src []byte) error

type MetadataResponse

+ func (v *MetadataResponse) UnsafeReadFrom(src []byte) error

type OffsetCommitKey

+ func (v *OffsetCommitKey) UnsafeReadFrom(src []byte) error

type OffsetCommitRequest

+ func (v *OffsetCommitRequest) UnsafeReadFrom(src []byte) error

type OffsetCommitResponse

+ func (v *OffsetCommitResponse) UnsafeReadFrom(src []byte) error

type OffsetCommitValue

+ func (v *OffsetCommitValue) UnsafeReadFrom(src []byte) error

type OffsetDeleteRequest

+ func (v *OffsetDeleteRequest) UnsafeReadFrom(src []byte) error

type OffsetDeleteResponse

+ func (v *OffsetDeleteResponse) UnsafeReadFrom(src []byte) error

type OffsetFetchRequest

+ func (v *OffsetFetchRequest) UnsafeReadFrom(src []byte) error

type OffsetFetchResponse

+ func (v *OffsetFetchResponse) UnsafeReadFrom(src []byte) error

type OffsetForLeaderEpochRequest

+ func (v *OffsetForLeaderEpochRequest) UnsafeReadFrom(src []byte) error

type OffsetForLeaderEpochResponse

+ func (v *OffsetForLeaderEpochResponse) UnsafeReadFrom(src []byte) error

type ProduceRequest

+ func (v *ProduceRequest) UnsafeReadFrom(src []byte) error

type ProduceResponse

+ func (v *ProduceResponse) UnsafeReadFrom(src []byte) error

type Record

+ func (v *Record) UnsafeReadFrom(src []byte) error

type RecordBatch

+ func (v *RecordBatch) UnsafeReadFrom(src []byte) error

type RenewDelegationTokenRequest

+ func (v *RenewDelegationTokenRequest) UnsafeReadFrom(src []byte) error

type RenewDelegationTokenResponse

+ func (v *RenewDelegationTokenResponse) UnsafeReadFrom(src []byte) error

type SASLAuthenticateRequest

+ func (v *SASLAuthenticateRequest) UnsafeReadFrom(src []byte) error

type SASLAuthenticateResponse

+ func (v *SASLAuthenticateResponse) UnsafeReadFrom(src []byte) error

type SASLHandshakeRequest

+ func (v *SASLHandshakeRequest) UnsafeReadFrom(src []byte) error

type SASLHandshakeResponse

+ func (v *SASLHandshakeResponse) UnsafeReadFrom(src []byte) error

type StickyMemberMetadata

+ func (s *StickyMemberMetadata) UnsafeReadFrom(src []byte) error

type StopReplicaRequest

+ func (v *StopReplicaRequest) UnsafeReadFrom(src []byte) error

type StopReplicaResponse

+ func (v *StopReplicaResponse) UnsafeReadFrom(src []byte) error

type SyncGroupRequest

+ func (v *SyncGroupRequest) UnsafeReadFrom(src []byte) error

type SyncGroupResponse

+ func (v *SyncGroupResponse) UnsafeReadFrom(src []byte) error

type TxnMetadataKey

+ func (v *TxnMetadataKey) UnsafeReadFrom(src []byte) error

type TxnMetadataValue

+ func (v *TxnMetadataValue) UnsafeReadFrom(src []byte) error

type TxnOffsetCommitRequest

+ func (v *TxnOffsetCommitRequest) UnsafeReadFrom(src []byte) error

type TxnOffsetCommitResponse

+ func (v *TxnOffsetCommitResponse) UnsafeReadFrom(src []byte) error

type UnregisterBrokerRequest

+ func (v *UnregisterBrokerRequest) UnsafeReadFrom(src []byte) error

type UnregisterBrokerResponse

+ func (v *UnregisterBrokerResponse) UnsafeReadFrom(src []byte) error

+ type UnsafeReadFrom interface

+ UnsafeReadFrom func([]byte) error

type UpdateFeaturesRequest

+ ValidateOnly bool

+ func (v *UpdateFeaturesRequest) UnsafeReadFrom(src []byte) error

type UpdateFeaturesRequestFeatureUpdate

+ UpgradeType int8

type UpdateFeaturesResponse

+ func (v *UpdateFeaturesResponse) UnsafeReadFrom(src []byte) error

type UpdateMetadataRequest

+ func (v *UpdateMetadataRequest) UnsafeReadFrom(src []byte) error

type UpdateMetadataResponse

+ func (v *UpdateMetadataResponse) UnsafeReadFrom(src []byte) error

type VoteRequest

+ func (v *VoteRequest) UnsafeReadFrom(src []byte) error

type VoteResponse

+ func (v *VoteResponse) UnsafeReadFrom(src []byte) error

type WriteTxnMarkersRequest

+ func (v *WriteTxnMarkersRequest) UnsafeReadFrom(src []byte) error

type WriteTxnMarkersResponse

+ func (v *WriteTxnMarkersResponse) UnsafeReadFrom(src []byte) error

v1.0.0

Mar 21, 2022

Changes in this version

+ const MaxKey

+ func ACLOperationStrings() []string

+ func ACLPermissionTypeStrings() []string

+ func ACLResourcePatternTypeStrings() []string

+ func ACLResourceTypeStrings() []string

+ func ConfigResourceTypeStrings() []string

+ func ConfigSourceStrings() []string

+ func ConfigTypeStrings() []string

+ func ControlRecordKeyTypeStrings() []string

+ func IncrementalAlterConfigOpStrings() []string

+ func NameForKey(key int16) string

+ func QuotasMatchTypeStrings() []string

+ func SkipTags(b TagReader)

+ func StringPtr(in string) *string

+ func TransactionStateStrings() []string

+ type ACLOperation int8

+ const ACLOperationAll

+ const ACLOperationAlter

+ const ACLOperationAlterConfigs

+ const ACLOperationAny

+ const ACLOperationClusterAction

+ const ACLOperationCreate

+ const ACLOperationDelete

+ const ACLOperationDescribe

+ const ACLOperationDescribeConfigs

+ const ACLOperationIdempotentWrite

+ const ACLOperationRead

+ const ACLOperationUnknown

+ const ACLOperationWrite

+ func ParseACLOperation(s string) (ACLOperation, error)

+ func (e *ACLOperation) UnmarshalText(text []byte) error

+ func (e ACLOperation) MarshalText() (text []byte, err error)

+ func (v ACLOperation) String() string

+ type ACLPermissionType int8

+ const ACLPermissionTypeAllow

+ const ACLPermissionTypeAny

+ const ACLPermissionTypeDeny

+ const ACLPermissionTypeUnknown

+ func ParseACLPermissionType(s string) (ACLPermissionType, error)

+ func (e *ACLPermissionType) UnmarshalText(text []byte) error

+ func (e ACLPermissionType) MarshalText() (text []byte, err error)

+ func (v ACLPermissionType) String() string

+ type ACLResourcePatternType int8

+ const ACLResourcePatternTypeAny

+ const ACLResourcePatternTypeLiteral

+ const ACLResourcePatternTypeMatch

+ const ACLResourcePatternTypePrefixed

+ const ACLResourcePatternTypeUnknown

+ func ParseACLResourcePatternType(s string) (ACLResourcePatternType, error)

+ func (e *ACLResourcePatternType) UnmarshalText(text []byte) error

+ func (e ACLResourcePatternType) MarshalText() (text []byte, err error)

+ func (v ACLResourcePatternType) String() string

+ type ACLResourceType int8

+ const ACLResourceTypeAny

+ const ACLResourceTypeCluster

+ const ACLResourceTypeDelegationToken

+ const ACLResourceTypeGroup

+ const ACLResourceTypeTopic

+ const ACLResourceTypeTransactionalId

+ const ACLResourceTypeUnknown

+ func ParseACLResourceType(s string) (ACLResourceType, error)

+ func (e *ACLResourceType) UnmarshalText(text []byte) error

+ func (e ACLResourceType) MarshalText() (text []byte, err error)

+ func (v ACLResourceType) String() string

+ type AddOffsetsToTxnRequest struct

+ Group string

+ ProducerEpoch int16

+ ProducerID int64

+ TransactionalID string

+ UnknownTags Tags

+ Version int16

+ func NewAddOffsetsToTxnRequest() AddOffsetsToTxnRequest

+ func NewPtrAddOffsetsToTxnRequest() *AddOffsetsToTxnRequest

+ func (*AddOffsetsToTxnRequest) Key() int16

+ func (*AddOffsetsToTxnRequest) MaxVersion() int16

+ func (v *AddOffsetsToTxnRequest) AppendTo(dst []byte) []byte

+ func (v *AddOffsetsToTxnRequest) Default()

+ func (v *AddOffsetsToTxnRequest) GetVersion() int16

+ func (v *AddOffsetsToTxnRequest) IsFlexible() bool

+ func (v *AddOffsetsToTxnRequest) IsTxnCoordinatorRequest()

+ func (v *AddOffsetsToTxnRequest) ReadFrom(src []byte) error

+ func (v *AddOffsetsToTxnRequest) RequestWith(ctx context.Context, r Requestor) (*AddOffsetsToTxnResponse, error)

+ func (v *AddOffsetsToTxnRequest) ResponseKind() Response

+ func (v *AddOffsetsToTxnRequest) SetVersion(version int16)

+ type AddOffsetsToTxnResponse struct

+ ErrorCode int16

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewAddOffsetsToTxnResponse() AddOffsetsToTxnResponse

+ func NewPtrAddOffsetsToTxnResponse() *AddOffsetsToTxnResponse

+ func (*AddOffsetsToTxnResponse) Key() int16

+ func (*AddOffsetsToTxnResponse) MaxVersion() int16

+ func (v *AddOffsetsToTxnResponse) AppendTo(dst []byte) []byte

+ func (v *AddOffsetsToTxnResponse) Default()

+ func (v *AddOffsetsToTxnResponse) GetVersion() int16

+ func (v *AddOffsetsToTxnResponse) IsFlexible() bool

+ func (v *AddOffsetsToTxnResponse) ReadFrom(src []byte) error

+ func (v *AddOffsetsToTxnResponse) RequestKind() Request

+ func (v *AddOffsetsToTxnResponse) SetVersion(version int16)

+ func (v *AddOffsetsToTxnResponse) Throttle() (int32, bool)

+ type AddPartitionsToTxnRequest struct

+ ProducerEpoch int16

+ ProducerID int64

+ Topics []AddPartitionsToTxnRequestTopic

+ TransactionalID string

+ UnknownTags Tags

+ Version int16

+ func NewAddPartitionsToTxnRequest() AddPartitionsToTxnRequest

+ func NewPtrAddPartitionsToTxnRequest() *AddPartitionsToTxnRequest

+ func (*AddPartitionsToTxnRequest) Key() int16

+ func (*AddPartitionsToTxnRequest) MaxVersion() int16

+ func (v *AddPartitionsToTxnRequest) AppendTo(dst []byte) []byte

+ func (v *AddPartitionsToTxnRequest) Default()

+ func (v *AddPartitionsToTxnRequest) GetVersion() int16

+ func (v *AddPartitionsToTxnRequest) IsFlexible() bool

+ func (v *AddPartitionsToTxnRequest) IsTxnCoordinatorRequest()

+ func (v *AddPartitionsToTxnRequest) ReadFrom(src []byte) error

+ func (v *AddPartitionsToTxnRequest) RequestWith(ctx context.Context, r Requestor) (*AddPartitionsToTxnResponse, error)

+ func (v *AddPartitionsToTxnRequest) ResponseKind() Response

+ func (v *AddPartitionsToTxnRequest) SetVersion(version int16)

+ type AddPartitionsToTxnRequestTopic struct

+ Partitions []int32

+ Topic string

+ UnknownTags Tags

+ func NewAddPartitionsToTxnRequestTopic() AddPartitionsToTxnRequestTopic

+ func (v *AddPartitionsToTxnRequestTopic) Default()

+ type AddPartitionsToTxnResponse struct

+ ThrottleMillis int32

+ Topics []AddPartitionsToTxnResponseTopic

+ UnknownTags Tags

+ Version int16

+ func NewAddPartitionsToTxnResponse() AddPartitionsToTxnResponse

+ func NewPtrAddPartitionsToTxnResponse() *AddPartitionsToTxnResponse

+ func (*AddPartitionsToTxnResponse) Key() int16

+ func (*AddPartitionsToTxnResponse) MaxVersion() int16

+ func (v *AddPartitionsToTxnResponse) AppendTo(dst []byte) []byte

+ func (v *AddPartitionsToTxnResponse) Default()

+ func (v *AddPartitionsToTxnResponse) GetVersion() int16

+ func (v *AddPartitionsToTxnResponse) IsFlexible() bool

+ func (v *AddPartitionsToTxnResponse) ReadFrom(src []byte) error

+ func (v *AddPartitionsToTxnResponse) RequestKind() Request

+ func (v *AddPartitionsToTxnResponse) SetVersion(version int16)

+ func (v *AddPartitionsToTxnResponse) Throttle() (int32, bool)

+ type AddPartitionsToTxnResponseTopic struct

+ Partitions []AddPartitionsToTxnResponseTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewAddPartitionsToTxnResponseTopic() AddPartitionsToTxnResponseTopic

+ func (v *AddPartitionsToTxnResponseTopic) Default()

+ type AddPartitionsToTxnResponseTopicPartition struct

+ ErrorCode int16

+ Partition int32

+ UnknownTags Tags

+ func NewAddPartitionsToTxnResponseTopicPartition() AddPartitionsToTxnResponseTopicPartition

+ func (v *AddPartitionsToTxnResponseTopicPartition) Default()

+ type AdminRequest interface

+ IsAdminRequest func()

+ type AllocateProducerIDsRequest struct

+ BrokerEpoch int64

+ BrokerID int32

+ UnknownTags Tags

+ Version int16

+ func NewAllocateProducerIDsRequest() AllocateProducerIDsRequest

+ func NewPtrAllocateProducerIDsRequest() *AllocateProducerIDsRequest

+ func (*AllocateProducerIDsRequest) Key() int16

+ func (*AllocateProducerIDsRequest) MaxVersion() int16

+ func (v *AllocateProducerIDsRequest) AppendTo(dst []byte) []byte

+ func (v *AllocateProducerIDsRequest) Default()

+ func (v *AllocateProducerIDsRequest) GetVersion() int16

+ func (v *AllocateProducerIDsRequest) IsFlexible() bool

+ func (v *AllocateProducerIDsRequest) ReadFrom(src []byte) error

+ func (v *AllocateProducerIDsRequest) RequestWith(ctx context.Context, r Requestor) (*AllocateProducerIDsResponse, error)

+ func (v *AllocateProducerIDsRequest) ResponseKind() Response

+ func (v *AllocateProducerIDsRequest) SetVersion(version int16)

+ type AllocateProducerIDsResponse struct

+ ErrorCode int16

+ ProducerIDLen int32

+ ProducerIDStart int64

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewAllocateProducerIDsResponse() AllocateProducerIDsResponse

+ func NewPtrAllocateProducerIDsResponse() *AllocateProducerIDsResponse

+ func (*AllocateProducerIDsResponse) Key() int16

+ func (*AllocateProducerIDsResponse) MaxVersion() int16

+ func (v *AllocateProducerIDsResponse) AppendTo(dst []byte) []byte

+ func (v *AllocateProducerIDsResponse) Default()

+ func (v *AllocateProducerIDsResponse) GetVersion() int16

+ func (v *AllocateProducerIDsResponse) IsFlexible() bool

+ func (v *AllocateProducerIDsResponse) ReadFrom(src []byte) error

+ func (v *AllocateProducerIDsResponse) RequestKind() Request

+ func (v *AllocateProducerIDsResponse) SetVersion(version int16)

+ func (v *AllocateProducerIDsResponse) Throttle() (int32, bool)

+ type AlterClientQuotasRequest struct

+ Entries []AlterClientQuotasRequestEntry

+ UnknownTags Tags

+ ValidateOnly bool

+ Version int16

+ func NewAlterClientQuotasRequest() AlterClientQuotasRequest

+ func NewPtrAlterClientQuotasRequest() *AlterClientQuotasRequest

+ func (*AlterClientQuotasRequest) Key() int16

+ func (*AlterClientQuotasRequest) MaxVersion() int16

+ func (v *AlterClientQuotasRequest) AppendTo(dst []byte) []byte

+ func (v *AlterClientQuotasRequest) Default()

+ func (v *AlterClientQuotasRequest) GetVersion() int16

+ func (v *AlterClientQuotasRequest) IsFlexible() bool

+ func (v *AlterClientQuotasRequest) ReadFrom(src []byte) error

+ func (v *AlterClientQuotasRequest) RequestWith(ctx context.Context, r Requestor) (*AlterClientQuotasResponse, error)

+ func (v *AlterClientQuotasRequest) ResponseKind() Response

+ func (v *AlterClientQuotasRequest) SetVersion(version int16)

+ type AlterClientQuotasRequestEntry struct

+ Entity []AlterClientQuotasRequestEntryEntity

+ Ops []AlterClientQuotasRequestEntryOp

+ UnknownTags Tags

+ func NewAlterClientQuotasRequestEntry() AlterClientQuotasRequestEntry

+ func (v *AlterClientQuotasRequestEntry) Default()

+ type AlterClientQuotasRequestEntryEntity struct

+ Name *string

+ Type string

+ UnknownTags Tags

+ func NewAlterClientQuotasRequestEntryEntity() AlterClientQuotasRequestEntryEntity

+ func (v *AlterClientQuotasRequestEntryEntity) Default()

+ type AlterClientQuotasRequestEntryOp struct

+ Key string

+ Remove bool

+ UnknownTags Tags

+ Value float64

+ func NewAlterClientQuotasRequestEntryOp() AlterClientQuotasRequestEntryOp

+ func (v *AlterClientQuotasRequestEntryOp) Default()

+ type AlterClientQuotasResponse struct

+ Entries []AlterClientQuotasResponseEntry

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewAlterClientQuotasResponse() AlterClientQuotasResponse

+ func NewPtrAlterClientQuotasResponse() *AlterClientQuotasResponse

+ func (*AlterClientQuotasResponse) Key() int16

+ func (*AlterClientQuotasResponse) MaxVersion() int16

+ func (v *AlterClientQuotasResponse) AppendTo(dst []byte) []byte

+ func (v *AlterClientQuotasResponse) Default()

+ func (v *AlterClientQuotasResponse) GetVersion() int16

+ func (v *AlterClientQuotasResponse) IsFlexible() bool

+ func (v *AlterClientQuotasResponse) ReadFrom(src []byte) error

+ func (v *AlterClientQuotasResponse) RequestKind() Request

+ func (v *AlterClientQuotasResponse) SetVersion(version int16)

+ func (v *AlterClientQuotasResponse) Throttle() (int32, bool)

+ type AlterClientQuotasResponseEntry struct

+ Entity []AlterClientQuotasResponseEntryEntity

+ ErrorCode int16

+ ErrorMessage *string

+ UnknownTags Tags

+ func NewAlterClientQuotasResponseEntry() AlterClientQuotasResponseEntry

+ func (v *AlterClientQuotasResponseEntry) Default()

+ type AlterClientQuotasResponseEntryEntity struct

+ Name *string

+ Type string

+ UnknownTags Tags

+ func NewAlterClientQuotasResponseEntryEntity() AlterClientQuotasResponseEntryEntity

+ func (v *AlterClientQuotasResponseEntryEntity) Default()

+ type AlterConfigsRequest struct

+ Resources []AlterConfigsRequestResource

+ UnknownTags Tags

+ ValidateOnly bool

+ Version int16

+ func NewAlterConfigsRequest() AlterConfigsRequest

+ func NewPtrAlterConfigsRequest() *AlterConfigsRequest

+ func (*AlterConfigsRequest) Key() int16

+ func (*AlterConfigsRequest) MaxVersion() int16

+ func (v *AlterConfigsRequest) AppendTo(dst []byte) []byte

+ func (v *AlterConfigsRequest) Default()

+ func (v *AlterConfigsRequest) GetVersion() int16

+ func (v *AlterConfigsRequest) IsFlexible() bool

+ func (v *AlterConfigsRequest) ReadFrom(src []byte) error

+ func (v *AlterConfigsRequest) RequestWith(ctx context.Context, r Requestor) (*AlterConfigsResponse, error)

+ func (v *AlterConfigsRequest) ResponseKind() Response

+ func (v *AlterConfigsRequest) SetVersion(version int16)

+ type AlterConfigsRequestResource struct

+ Configs []AlterConfigsRequestResourceConfig

+ ResourceName string

+ ResourceType ConfigResourceType

+ UnknownTags Tags

+ func NewAlterConfigsRequestResource() AlterConfigsRequestResource

+ func (v *AlterConfigsRequestResource) Default()

+ type AlterConfigsRequestResourceConfig struct

+ Name string

+ UnknownTags Tags

+ Value *string

+ func NewAlterConfigsRequestResourceConfig() AlterConfigsRequestResourceConfig

+ func (v *AlterConfigsRequestResourceConfig) Default()

+ type AlterConfigsResponse struct

+ Resources []AlterConfigsResponseResource

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewAlterConfigsResponse() AlterConfigsResponse

+ func NewPtrAlterConfigsResponse() *AlterConfigsResponse

+ func (*AlterConfigsResponse) Key() int16

+ func (*AlterConfigsResponse) MaxVersion() int16

+ func (v *AlterConfigsResponse) AppendTo(dst []byte) []byte

+ func (v *AlterConfigsResponse) Default()

+ func (v *AlterConfigsResponse) GetVersion() int16

+ func (v *AlterConfigsResponse) IsFlexible() bool

+ func (v *AlterConfigsResponse) ReadFrom(src []byte) error

+ func (v *AlterConfigsResponse) RequestKind() Request

+ func (v *AlterConfigsResponse) SetVersion(version int16)

+ func (v *AlterConfigsResponse) Throttle() (int32, bool)

+ type AlterConfigsResponseResource struct

+ ErrorCode int16

+ ErrorMessage *string

+ ResourceName string

+ ResourceType ConfigResourceType

+ UnknownTags Tags

+ func NewAlterConfigsResponseResource() AlterConfigsResponseResource

+ func (v *AlterConfigsResponseResource) Default()

+ type AlterPartitionAssignmentsRequest struct

+ TimeoutMillis int32

+ Topics []AlterPartitionAssignmentsRequestTopic

+ UnknownTags Tags

+ Version int16

+ func NewAlterPartitionAssignmentsRequest() AlterPartitionAssignmentsRequest

+ func NewPtrAlterPartitionAssignmentsRequest() *AlterPartitionAssignmentsRequest

+ func (*AlterPartitionAssignmentsRequest) Key() int16

+ func (*AlterPartitionAssignmentsRequest) MaxVersion() int16

+ func (v *AlterPartitionAssignmentsRequest) AppendTo(dst []byte) []byte

+ func (v *AlterPartitionAssignmentsRequest) Default()

+ func (v *AlterPartitionAssignmentsRequest) GetVersion() int16

+ func (v *AlterPartitionAssignmentsRequest) IsAdminRequest()

+ func (v *AlterPartitionAssignmentsRequest) IsFlexible() bool

+ func (v *AlterPartitionAssignmentsRequest) ReadFrom(src []byte) error

+ func (v *AlterPartitionAssignmentsRequest) RequestWith(ctx context.Context, r Requestor) (*AlterPartitionAssignmentsResponse, error)

+ func (v *AlterPartitionAssignmentsRequest) ResponseKind() Response

+ func (v *AlterPartitionAssignmentsRequest) SetVersion(version int16)

+ func (v *AlterPartitionAssignmentsRequest) Timeout() int32

+ type AlterPartitionAssignmentsRequestTopic struct

+ Partitions []AlterPartitionAssignmentsRequestTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewAlterPartitionAssignmentsRequestTopic() AlterPartitionAssignmentsRequestTopic

+ func (v *AlterPartitionAssignmentsRequestTopic) Default()

+ type AlterPartitionAssignmentsRequestTopicPartition struct

+ Partition int32

+ Replicas []int32

+ UnknownTags Tags

+ func NewAlterPartitionAssignmentsRequestTopicPartition() AlterPartitionAssignmentsRequestTopicPartition

+ func (v *AlterPartitionAssignmentsRequestTopicPartition) Default()

+ type AlterPartitionAssignmentsResponse struct

+ ErrorCode int16

+ ErrorMessage *string

+ ThrottleMillis int32

+ Topics []AlterPartitionAssignmentsResponseTopic

+ UnknownTags Tags

+ Version int16

+ func NewAlterPartitionAssignmentsResponse() AlterPartitionAssignmentsResponse

+ func NewPtrAlterPartitionAssignmentsResponse() *AlterPartitionAssignmentsResponse

+ func (*AlterPartitionAssignmentsResponse) Key() int16

+ func (*AlterPartitionAssignmentsResponse) MaxVersion() int16

+ func (v *AlterPartitionAssignmentsResponse) AppendTo(dst []byte) []byte

+ func (v *AlterPartitionAssignmentsResponse) Default()

+ func (v *AlterPartitionAssignmentsResponse) GetVersion() int16

+ func (v *AlterPartitionAssignmentsResponse) IsFlexible() bool

+ func (v *AlterPartitionAssignmentsResponse) ReadFrom(src []byte) error

+ func (v *AlterPartitionAssignmentsResponse) RequestKind() Request

+ func (v *AlterPartitionAssignmentsResponse) SetVersion(version int16)

+ func (v *AlterPartitionAssignmentsResponse) Throttle() (int32, bool)

+ type AlterPartitionAssignmentsResponseTopic struct

+ Partitions []AlterPartitionAssignmentsResponseTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewAlterPartitionAssignmentsResponseTopic() AlterPartitionAssignmentsResponseTopic

+ func (v *AlterPartitionAssignmentsResponseTopic) Default()

+ type AlterPartitionAssignmentsResponseTopicPartition struct

+ ErrorCode int16

+ ErrorMessage *string

+ Partition int32

+ UnknownTags Tags

+ func NewAlterPartitionAssignmentsResponseTopicPartition() AlterPartitionAssignmentsResponseTopicPartition

+ func (v *AlterPartitionAssignmentsResponseTopicPartition) Default()

+ type AlterPartitionRequest struct

+ BrokerEpoch int64

+ BrokerID int32

+ Topics []AlterPartitionRequestTopic

+ UnknownTags Tags

+ Version int16

+ func NewAlterPartitionRequest() AlterPartitionRequest

+ func NewPtrAlterPartitionRequest() *AlterPartitionRequest

+ func (*AlterPartitionRequest) Key() int16

+ func (*AlterPartitionRequest) MaxVersion() int16

+ func (v *AlterPartitionRequest) AppendTo(dst []byte) []byte

+ func (v *AlterPartitionRequest) Default()

+ func (v *AlterPartitionRequest) GetVersion() int16

+ func (v *AlterPartitionRequest) IsAdminRequest()

+ func (v *AlterPartitionRequest) IsFlexible() bool

+ func (v *AlterPartitionRequest) ReadFrom(src []byte) error

+ func (v *AlterPartitionRequest) RequestWith(ctx context.Context, r Requestor) (*AlterPartitionResponse, error)

+ func (v *AlterPartitionRequest) ResponseKind() Response

+ func (v *AlterPartitionRequest) SetVersion(version int16)

+ type AlterPartitionRequestTopic struct

+ Partitions []AlterPartitionRequestTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewAlterPartitionRequestTopic() AlterPartitionRequestTopic

+ func (v *AlterPartitionRequestTopic) Default()

+ type AlterPartitionRequestTopicPartition struct

+ LeaderEpoch int32

+ LeaderRecoveryState int8

+ NewISR []int32

+ Partition int32

+ PartitionEpoch int32

+ UnknownTags Tags

+ func NewAlterPartitionRequestTopicPartition() AlterPartitionRequestTopicPartition

+ func (v *AlterPartitionRequestTopicPartition) Default()

+ type AlterPartitionResponse struct

+ ErrorCode int16

+ ThrottleMillis int32

+ Topics []AlterPartitionResponseTopic

+ UnknownTags Tags

+ Version int16

+ func NewAlterPartitionResponse() AlterPartitionResponse

+ func NewPtrAlterPartitionResponse() *AlterPartitionResponse

+ func (*AlterPartitionResponse) Key() int16

+ func (*AlterPartitionResponse) MaxVersion() int16

+ func (v *AlterPartitionResponse) AppendTo(dst []byte) []byte

+ func (v *AlterPartitionResponse) Default()

+ func (v *AlterPartitionResponse) GetVersion() int16

+ func (v *AlterPartitionResponse) IsFlexible() bool

+ func (v *AlterPartitionResponse) ReadFrom(src []byte) error

+ func (v *AlterPartitionResponse) RequestKind() Request

+ func (v *AlterPartitionResponse) SetVersion(version int16)

+ func (v *AlterPartitionResponse) Throttle() (int32, bool)

+ type AlterPartitionResponseTopic struct

+ Partitions []AlterPartitionResponseTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewAlterPartitionResponseTopic() AlterPartitionResponseTopic

+ func (v *AlterPartitionResponseTopic) Default()

+ type AlterPartitionResponseTopicPartition struct

+ ErrorCode int16

+ ISR []int32

+ LeaderEpoch int32

+ LeaderID int32

+ LeaderRecoveryState int8

+ Partition int32

+ PartitionEpoch int32

+ UnknownTags Tags

+ func NewAlterPartitionResponseTopicPartition() AlterPartitionResponseTopicPartition

+ func (v *AlterPartitionResponseTopicPartition) Default()

+ type AlterReplicaLogDirsRequest struct

+ Dirs []AlterReplicaLogDirsRequestDir

+ UnknownTags Tags

+ Version int16

+ func NewAlterReplicaLogDirsRequest() AlterReplicaLogDirsRequest

+ func NewPtrAlterReplicaLogDirsRequest() *AlterReplicaLogDirsRequest

+ func (*AlterReplicaLogDirsRequest) Key() int16

+ func (*AlterReplicaLogDirsRequest) MaxVersion() int16

+ func (v *AlterReplicaLogDirsRequest) AppendTo(dst []byte) []byte

+ func (v *AlterReplicaLogDirsRequest) Default()

+ func (v *AlterReplicaLogDirsRequest) GetVersion() int16

+ func (v *AlterReplicaLogDirsRequest) IsFlexible() bool

+ func (v *AlterReplicaLogDirsRequest) ReadFrom(src []byte) error

+ func (v *AlterReplicaLogDirsRequest) RequestWith(ctx context.Context, r Requestor) (*AlterReplicaLogDirsResponse, error)

+ func (v *AlterReplicaLogDirsRequest) ResponseKind() Response

+ func (v *AlterReplicaLogDirsRequest) SetVersion(version int16)

+ type AlterReplicaLogDirsRequestDir struct

+ Dir string

+ Topics []AlterReplicaLogDirsRequestDirTopic

+ UnknownTags Tags

+ func NewAlterReplicaLogDirsRequestDir() AlterReplicaLogDirsRequestDir

+ func (v *AlterReplicaLogDirsRequestDir) Default()

+ type AlterReplicaLogDirsRequestDirTopic struct

+ Partitions []int32

+ Topic string

+ UnknownTags Tags

+ func NewAlterReplicaLogDirsRequestDirTopic() AlterReplicaLogDirsRequestDirTopic

+ func (v *AlterReplicaLogDirsRequestDirTopic) Default()

+ type AlterReplicaLogDirsResponse struct

+ ThrottleMillis int32

+ Topics []AlterReplicaLogDirsResponseTopic

+ UnknownTags Tags

+ Version int16

+ func NewAlterReplicaLogDirsResponse() AlterReplicaLogDirsResponse

+ func NewPtrAlterReplicaLogDirsResponse() *AlterReplicaLogDirsResponse

+ func (*AlterReplicaLogDirsResponse) Key() int16

+ func (*AlterReplicaLogDirsResponse) MaxVersion() int16

+ func (v *AlterReplicaLogDirsResponse) AppendTo(dst []byte) []byte

+ func (v *AlterReplicaLogDirsResponse) Default()

+ func (v *AlterReplicaLogDirsResponse) GetVersion() int16

+ func (v *AlterReplicaLogDirsResponse) IsFlexible() bool

+ func (v *AlterReplicaLogDirsResponse) ReadFrom(src []byte) error

+ func (v *AlterReplicaLogDirsResponse) RequestKind() Request

+ func (v *AlterReplicaLogDirsResponse) SetVersion(version int16)

+ func (v *AlterReplicaLogDirsResponse) Throttle() (int32, bool)

+ type AlterReplicaLogDirsResponseTopic struct

+ Partitions []AlterReplicaLogDirsResponseTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewAlterReplicaLogDirsResponseTopic() AlterReplicaLogDirsResponseTopic

+ func (v *AlterReplicaLogDirsResponseTopic) Default()

+ type AlterReplicaLogDirsResponseTopicPartition struct

+ ErrorCode int16

+ Partition int32

+ UnknownTags Tags

+ func NewAlterReplicaLogDirsResponseTopicPartition() AlterReplicaLogDirsResponseTopicPartition

+ func (v *AlterReplicaLogDirsResponseTopicPartition) Default()

+ type AlterUserSCRAMCredentialsRequest struct

+ Deletions []AlterUserSCRAMCredentialsRequestDeletion

+ UnknownTags Tags

+ Upsertions []AlterUserSCRAMCredentialsRequestUpsertion

+ Version int16

+ func NewAlterUserSCRAMCredentialsRequest() AlterUserSCRAMCredentialsRequest

+ func NewPtrAlterUserSCRAMCredentialsRequest() *AlterUserSCRAMCredentialsRequest

+ func (*AlterUserSCRAMCredentialsRequest) Key() int16

+ func (*AlterUserSCRAMCredentialsRequest) MaxVersion() int16

+ func (v *AlterUserSCRAMCredentialsRequest) AppendTo(dst []byte) []byte

+ func (v *AlterUserSCRAMCredentialsRequest) Default()

+ func (v *AlterUserSCRAMCredentialsRequest) GetVersion() int16

+ func (v *AlterUserSCRAMCredentialsRequest) IsAdminRequest()

+ func (v *AlterUserSCRAMCredentialsRequest) IsFlexible() bool

+ func (v *AlterUserSCRAMCredentialsRequest) ReadFrom(src []byte) error

+ func (v *AlterUserSCRAMCredentialsRequest) RequestWith(ctx context.Context, r Requestor) (*AlterUserSCRAMCredentialsResponse, error)

+ func (v *AlterUserSCRAMCredentialsRequest) ResponseKind() Response

+ func (v *AlterUserSCRAMCredentialsRequest) SetVersion(version int16)

+ type AlterUserSCRAMCredentialsRequestDeletion struct

+ Mechanism int8

+ Name string

+ UnknownTags Tags

+ func NewAlterUserSCRAMCredentialsRequestDeletion() AlterUserSCRAMCredentialsRequestDeletion

+ func (v *AlterUserSCRAMCredentialsRequestDeletion) Default()

+ type AlterUserSCRAMCredentialsRequestUpsertion struct

+ Iterations int32

+ Mechanism int8

+ Name string

+ Salt []byte

+ SaltedPassword []byte

+ UnknownTags Tags

+ func NewAlterUserSCRAMCredentialsRequestUpsertion() AlterUserSCRAMCredentialsRequestUpsertion

+ func (v *AlterUserSCRAMCredentialsRequestUpsertion) Default()

+ type AlterUserSCRAMCredentialsResponse struct

+ Results []AlterUserSCRAMCredentialsResponseResult

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewAlterUserSCRAMCredentialsResponse() AlterUserSCRAMCredentialsResponse

+ func NewPtrAlterUserSCRAMCredentialsResponse() *AlterUserSCRAMCredentialsResponse

+ func (*AlterUserSCRAMCredentialsResponse) Key() int16

+ func (*AlterUserSCRAMCredentialsResponse) MaxVersion() int16

+ func (v *AlterUserSCRAMCredentialsResponse) AppendTo(dst []byte) []byte

+ func (v *AlterUserSCRAMCredentialsResponse) Default()

+ func (v *AlterUserSCRAMCredentialsResponse) GetVersion() int16

+ func (v *AlterUserSCRAMCredentialsResponse) IsFlexible() bool

+ func (v *AlterUserSCRAMCredentialsResponse) ReadFrom(src []byte) error

+ func (v *AlterUserSCRAMCredentialsResponse) RequestKind() Request

+ func (v *AlterUserSCRAMCredentialsResponse) SetVersion(version int16)

+ func (v *AlterUserSCRAMCredentialsResponse) Throttle() (int32, bool)

+ type AlterUserSCRAMCredentialsResponseResult struct

+ ErrorCode int16

+ ErrorMessage *string

+ UnknownTags Tags

+ User string

+ func NewAlterUserSCRAMCredentialsResponseResult() AlterUserSCRAMCredentialsResponseResult

+ func (v *AlterUserSCRAMCredentialsResponseResult) Default()

+ type ApiVersionsRequest struct

+ ClientSoftwareName string

+ ClientSoftwareVersion string

+ UnknownTags Tags

+ Version int16

+ func NewApiVersionsRequest() ApiVersionsRequest

+ func NewPtrApiVersionsRequest() *ApiVersionsRequest

+ func (*ApiVersionsRequest) Key() int16

+ func (*ApiVersionsRequest) MaxVersion() int16

+ func (v *ApiVersionsRequest) AppendTo(dst []byte) []byte

+ func (v *ApiVersionsRequest) Default()

+ func (v *ApiVersionsRequest) GetVersion() int16

+ func (v *ApiVersionsRequest) IsFlexible() bool

+ func (v *ApiVersionsRequest) ReadFrom(src []byte) error

+ func (v *ApiVersionsRequest) RequestWith(ctx context.Context, r Requestor) (*ApiVersionsResponse, error)

+ func (v *ApiVersionsRequest) ResponseKind() Response

+ func (v *ApiVersionsRequest) SetVersion(version int16)

+ type ApiVersionsResponse struct

+ ApiKeys []ApiVersionsResponseApiKey

+ ErrorCode int16

+ FinalizedFeatures []ApiVersionsResponseFinalizedFeature

+ FinalizedFeaturesEpoch int64

+ SupportedFeatures []ApiVersionsResponseSupportedFeature

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewApiVersionsResponse() ApiVersionsResponse

+ func NewPtrApiVersionsResponse() *ApiVersionsResponse

+ func (*ApiVersionsResponse) Key() int16

+ func (*ApiVersionsResponse) MaxVersion() int16

+ func (v *ApiVersionsResponse) AppendTo(dst []byte) []byte

+ func (v *ApiVersionsResponse) Default()

+ func (v *ApiVersionsResponse) GetVersion() int16

+ func (v *ApiVersionsResponse) IsFlexible() bool

+ func (v *ApiVersionsResponse) ReadFrom(src []byte) error

+ func (v *ApiVersionsResponse) RequestKind() Request

+ func (v *ApiVersionsResponse) SetVersion(version int16)

+ func (v *ApiVersionsResponse) Throttle() (int32, bool)

+ type ApiVersionsResponseApiKey struct

+ ApiKey int16

+ MaxVersion int16

+ MinVersion int16

+ UnknownTags Tags

+ func NewApiVersionsResponseApiKey() ApiVersionsResponseApiKey

+ func (v *ApiVersionsResponseApiKey) Default()

+ type ApiVersionsResponseFinalizedFeature struct

+ MaxVersionLevel int16

+ MinVersionLevel int16

+ Name string

+ UnknownTags Tags

+ func NewApiVersionsResponseFinalizedFeature() ApiVersionsResponseFinalizedFeature

+ func (v *ApiVersionsResponseFinalizedFeature) Default()

+ type ApiVersionsResponseSupportedFeature struct

+ MaxVersion int16

+ MinVersion int16

+ Name string

+ UnknownTags Tags

+ func NewApiVersionsResponseSupportedFeature() ApiVersionsResponseSupportedFeature

+ func (v *ApiVersionsResponseSupportedFeature) Default()

+ type BeginQuorumEpochRequest struct

+ ClusterID *string

+ Topics []BeginQuorumEpochRequestTopic

+ Version int16

+ func NewBeginQuorumEpochRequest() BeginQuorumEpochRequest

+ func NewPtrBeginQuorumEpochRequest() *BeginQuorumEpochRequest

+ func (*BeginQuorumEpochRequest) Key() int16

+ func (*BeginQuorumEpochRequest) MaxVersion() int16

+ func (v *BeginQuorumEpochRequest) AppendTo(dst []byte) []byte

+ func (v *BeginQuorumEpochRequest) Default()

+ func (v *BeginQuorumEpochRequest) GetVersion() int16

+ func (v *BeginQuorumEpochRequest) IsAdminRequest()

+ func (v *BeginQuorumEpochRequest) IsFlexible() bool

+ func (v *BeginQuorumEpochRequest) ReadFrom(src []byte) error

+ func (v *BeginQuorumEpochRequest) RequestWith(ctx context.Context, r Requestor) (*BeginQuorumEpochResponse, error)

+ func (v *BeginQuorumEpochRequest) ResponseKind() Response

+ func (v *BeginQuorumEpochRequest) SetVersion(version int16)

+ type BeginQuorumEpochRequestTopic struct

+ Partitions []BeginQuorumEpochRequestTopicPartition

+ Topic string

+ func NewBeginQuorumEpochRequestTopic() BeginQuorumEpochRequestTopic

+ func (v *BeginQuorumEpochRequestTopic) Default()

+ type BeginQuorumEpochRequestTopicPartition struct

+ LeaderEpoch int32

+ LeaderID int32

+ Partition int32

+ func NewBeginQuorumEpochRequestTopicPartition() BeginQuorumEpochRequestTopicPartition

+ func (v *BeginQuorumEpochRequestTopicPartition) Default()

+ type BeginQuorumEpochResponse struct

+ ErrorCode int16

+ Topics []BeginQuorumEpochResponseTopic

+ Version int16

+ func NewBeginQuorumEpochResponse() BeginQuorumEpochResponse

+ func NewPtrBeginQuorumEpochResponse() *BeginQuorumEpochResponse

+ func (*BeginQuorumEpochResponse) Key() int16

+ func (*BeginQuorumEpochResponse) MaxVersion() int16

+ func (v *BeginQuorumEpochResponse) AppendTo(dst []byte) []byte

+ func (v *BeginQuorumEpochResponse) Default()

+ func (v *BeginQuorumEpochResponse) GetVersion() int16

+ func (v *BeginQuorumEpochResponse) IsFlexible() bool

+ func (v *BeginQuorumEpochResponse) ReadFrom(src []byte) error

+ func (v *BeginQuorumEpochResponse) RequestKind() Request

+ func (v *BeginQuorumEpochResponse) SetVersion(version int16)

+ type BeginQuorumEpochResponseTopic struct

+ Partitions []BeginQuorumEpochResponseTopicPartition

+ Topic string

+ func NewBeginQuorumEpochResponseTopic() BeginQuorumEpochResponseTopic

+ func (v *BeginQuorumEpochResponseTopic) Default()

+ type BeginQuorumEpochResponseTopicPartition struct

+ ErrorCode int16

+ LeaderEpoch int32

+ LeaderID int32

+ Partition int32

+ func NewBeginQuorumEpochResponseTopicPartition() BeginQuorumEpochResponseTopicPartition

+ func (v *BeginQuorumEpochResponseTopicPartition) Default()

+ type BrokerHeartbeatRequest struct

+ BrokerEpoch int64

+ BrokerID int32

+ CurrentMetadataOffset int64

+ UnknownTags Tags

+ Version int16

+ WantFence bool

+ WantShutdown bool

+ func NewBrokerHeartbeatRequest() BrokerHeartbeatRequest

+ func NewPtrBrokerHeartbeatRequest() *BrokerHeartbeatRequest

+ func (*BrokerHeartbeatRequest) Key() int16

+ func (*BrokerHeartbeatRequest) MaxVersion() int16

+ func (v *BrokerHeartbeatRequest) AppendTo(dst []byte) []byte

+ func (v *BrokerHeartbeatRequest) Default()

+ func (v *BrokerHeartbeatRequest) GetVersion() int16

+ func (v *BrokerHeartbeatRequest) IsFlexible() bool

+ func (v *BrokerHeartbeatRequest) ReadFrom(src []byte) error

+ func (v *BrokerHeartbeatRequest) RequestWith(ctx context.Context, r Requestor) (*BrokerHeartbeatResponse, error)

+ func (v *BrokerHeartbeatRequest) ResponseKind() Response

+ func (v *BrokerHeartbeatRequest) SetVersion(version int16)

+ type BrokerHeartbeatResponse struct

+ ErrorCode int16

+ IsCaughtUp bool

+ IsFenced bool

+ ShouldShutdown bool

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewBrokerHeartbeatResponse() BrokerHeartbeatResponse

+ func NewPtrBrokerHeartbeatResponse() *BrokerHeartbeatResponse

+ func (*BrokerHeartbeatResponse) Key() int16

+ func (*BrokerHeartbeatResponse) MaxVersion() int16

+ func (v *BrokerHeartbeatResponse) AppendTo(dst []byte) []byte

+ func (v *BrokerHeartbeatResponse) Default()

+ func (v *BrokerHeartbeatResponse) GetVersion() int16

+ func (v *BrokerHeartbeatResponse) IsFlexible() bool

+ func (v *BrokerHeartbeatResponse) ReadFrom(src []byte) error

+ func (v *BrokerHeartbeatResponse) RequestKind() Request

+ func (v *BrokerHeartbeatResponse) SetVersion(version int16)

+ func (v *BrokerHeartbeatResponse) Throttle() (int32, bool)

+ type BrokerRegistrationRequest struct

+ BrokerID int32

+ ClusterID string

+ Features []BrokerRegistrationRequestFeature

+ IncarnationID [16]byte

+ Listeners []BrokerRegistrationRequestListener

+ Rack *string

+ UnknownTags Tags

+ Version int16

+ func NewBrokerRegistrationRequest() BrokerRegistrationRequest

+ func NewPtrBrokerRegistrationRequest() *BrokerRegistrationRequest

+ func (*BrokerRegistrationRequest) Key() int16

+ func (*BrokerRegistrationRequest) MaxVersion() int16

+ func (v *BrokerRegistrationRequest) AppendTo(dst []byte) []byte

+ func (v *BrokerRegistrationRequest) Default()

+ func (v *BrokerRegistrationRequest) GetVersion() int16

+ func (v *BrokerRegistrationRequest) IsFlexible() bool

+ func (v *BrokerRegistrationRequest) ReadFrom(src []byte) error

+ func (v *BrokerRegistrationRequest) RequestWith(ctx context.Context, r Requestor) (*BrokerRegistrationResponse, error)

+ func (v *BrokerRegistrationRequest) ResponseKind() Response

+ func (v *BrokerRegistrationRequest) SetVersion(version int16)

+ type BrokerRegistrationRequestFeature struct

+ MaxSupportedVersion int16

+ MinSupportedVersion int16

+ Name string

+ UnknownTags Tags

+ func NewBrokerRegistrationRequestFeature() BrokerRegistrationRequestFeature

+ func (v *BrokerRegistrationRequestFeature) Default()

+ type BrokerRegistrationRequestListener struct

+ Host string

+ Name string

+ Port uint16

+ SecurityProtocol int16

+ UnknownTags Tags

+ func NewBrokerRegistrationRequestListener() BrokerRegistrationRequestListener

+ func (v *BrokerRegistrationRequestListener) Default()

+ type BrokerRegistrationResponse struct

+ BrokerEpoch int64

+ ErrorCode int16

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewBrokerRegistrationResponse() BrokerRegistrationResponse

+ func NewPtrBrokerRegistrationResponse() *BrokerRegistrationResponse

+ func (*BrokerRegistrationResponse) Key() int16

+ func (*BrokerRegistrationResponse) MaxVersion() int16

+ func (v *BrokerRegistrationResponse) AppendTo(dst []byte) []byte

+ func (v *BrokerRegistrationResponse) Default()

+ func (v *BrokerRegistrationResponse) GetVersion() int16

+ func (v *BrokerRegistrationResponse) IsFlexible() bool

+ func (v *BrokerRegistrationResponse) ReadFrom(src []byte) error

+ func (v *BrokerRegistrationResponse) RequestKind() Request

+ func (v *BrokerRegistrationResponse) SetVersion(version int16)

+ func (v *BrokerRegistrationResponse) Throttle() (int32, bool)

+ type ConfigResourceType int8

+ const ConfigResourceTypeBroker

+ const ConfigResourceTypeBrokerLogger

+ const ConfigResourceTypeTopic

+ const ConfigResourceTypeUnknown

+ func ParseConfigResourceType(s string) (ConfigResourceType, error)

+ func (e *ConfigResourceType) UnmarshalText(text []byte) error

+ func (e ConfigResourceType) MarshalText() (text []byte, err error)

+ func (v ConfigResourceType) String() string

+ type ConfigSource int8

+ const ConfigSourceDefaultConfig

+ const ConfigSourceDynamicBrokerConfig

+ const ConfigSourceDynamicBrokerLoggerConfig

+ const ConfigSourceDynamicDefaultBrokerConfig

+ const ConfigSourceDynamicTopicConfig

+ const ConfigSourceStaticBrokerConfig

+ const ConfigSourceUnknown

+ func ParseConfigSource(s string) (ConfigSource, error)

+ func (e *ConfigSource) UnmarshalText(text []byte) error

+ func (e ConfigSource) MarshalText() (text []byte, err error)

+ func (v ConfigSource) String() string

+ type ConfigType int8

+ const ConfigTypeBoolean

+ const ConfigTypeClass

+ const ConfigTypeDouble

+ const ConfigTypeInt

+ const ConfigTypeList

+ const ConfigTypeLong

+ const ConfigTypePassword

+ const ConfigTypeShort

+ const ConfigTypeString

+ const ConfigTypeUnknown

+ func ParseConfigType(s string) (ConfigType, error)

+ func (e *ConfigType) UnmarshalText(text []byte) error

+ func (e ConfigType) MarshalText() (text []byte, err error)

+ func (v ConfigType) String() string

+ type ConnectMemberAssignment struct

+ Assignment []ConnectMemberAssignmentAssignment

+ ConfigOffset int64

+ Error int16

+ Leader string

+ LeaderURL string

+ Revoked []ConnectMemberAssignmentRevoked

+ ScheduledDelay int32

+ Version int16

+ func NewConnectMemberAssignment() ConnectMemberAssignment

+ func (v *ConnectMemberAssignment) AppendTo(dst []byte) []byte

+ func (v *ConnectMemberAssignment) Default()

+ func (v *ConnectMemberAssignment) ReadFrom(src []byte) error

+ type ConnectMemberAssignmentAssignment struct

+ Connector string

+ Tasks []int16

+ func NewConnectMemberAssignmentAssignment() ConnectMemberAssignmentAssignment

+ func (v *ConnectMemberAssignmentAssignment) Default()

+ type ConnectMemberAssignmentRevoked struct

+ Connector string

+ Tasks []int16

+ func NewConnectMemberAssignmentRevoked() ConnectMemberAssignmentRevoked

+ func (v *ConnectMemberAssignmentRevoked) Default()

+ type ConnectMemberMetadata struct

+ ConfigOffset int64

+ CurrentAssignment []byte

+ URL string

+ Version int16

+ func NewConnectMemberMetadata() ConnectMemberMetadata

+ func (v *ConnectMemberMetadata) AppendTo(dst []byte) []byte

+ func (v *ConnectMemberMetadata) Default()

+ func (v *ConnectMemberMetadata) ReadFrom(src []byte) error

+ type ConsumerMemberAssignment struct

+ Topics []ConsumerMemberAssignmentTopic

+ UserData []byte

+ Version int16

+ func NewConsumerMemberAssignment() ConsumerMemberAssignment

+ func (v *ConsumerMemberAssignment) AppendTo(dst []byte) []byte

+ func (v *ConsumerMemberAssignment) Default()

+ func (v *ConsumerMemberAssignment) ReadFrom(src []byte) error

+ type ConsumerMemberAssignmentTopic struct

+ Partitions []int32

+ Topic string

+ func NewConsumerMemberAssignmentTopic() ConsumerMemberAssignmentTopic

+ func (v *ConsumerMemberAssignmentTopic) Default()

+ type ConsumerMemberMetadata struct

+ OwnedPartitions []ConsumerMemberMetadataOwnedPartition

+ Topics []string

+ UserData []byte

+ Version int16

+ func NewConsumerMemberMetadata() ConsumerMemberMetadata

+ func (v *ConsumerMemberMetadata) AppendTo(dst []byte) []byte

+ func (v *ConsumerMemberMetadata) Default()

+ func (v *ConsumerMemberMetadata) ReadFrom(src []byte) error

+ type ConsumerMemberMetadataOwnedPartition struct

+ Partitions []int32

+ Topic string

+ func NewConsumerMemberMetadataOwnedPartition() ConsumerMemberMetadataOwnedPartition

+ func (v *ConsumerMemberMetadataOwnedPartition) Default()

+ type ControlRecordKey struct

+ Type ControlRecordKeyType

+ Version int16

+ func NewControlRecordKey() ControlRecordKey

+ func (v *ControlRecordKey) AppendTo(dst []byte) []byte

+ func (v *ControlRecordKey) Default()

+ func (v *ControlRecordKey) ReadFrom(src []byte) error

+ type ControlRecordKeyType int8

+ const ControlRecordKeyTypeAbort

+ const ControlRecordKeyTypeCommit

+ const ControlRecordKeyTypeLeaderChange

+ const ControlRecordKeyTypeQuorumReassignment

+ func ParseControlRecordKeyType(s string) (ControlRecordKeyType, error)

+ func (e *ControlRecordKeyType) UnmarshalText(text []byte) error

+ func (e ControlRecordKeyType) MarshalText() (text []byte, err error)

+ func (v ControlRecordKeyType) String() string

+ type ControlledShutdownRequest struct

+ BrokerEpoch int64

+ BrokerID int32

+ UnknownTags Tags

+ Version int16

+ func NewControlledShutdownRequest() ControlledShutdownRequest

+ func NewPtrControlledShutdownRequest() *ControlledShutdownRequest

+ func (*ControlledShutdownRequest) Key() int16

+ func (*ControlledShutdownRequest) MaxVersion() int16

+ func (v *ControlledShutdownRequest) AppendTo(dst []byte) []byte

+ func (v *ControlledShutdownRequest) Default()

+ func (v *ControlledShutdownRequest) GetVersion() int16

+ func (v *ControlledShutdownRequest) IsFlexible() bool

+ func (v *ControlledShutdownRequest) ReadFrom(src []byte) error

+ func (v *ControlledShutdownRequest) RequestWith(ctx context.Context, r Requestor) (*ControlledShutdownResponse, error)

+ func (v *ControlledShutdownRequest) ResponseKind() Response

+ func (v *ControlledShutdownRequest) SetVersion(version int16)

+ type ControlledShutdownResponse struct

+ ErrorCode int16

+ PartitionsRemaining []ControlledShutdownResponsePartitionsRemaining

+ UnknownTags Tags

+ Version int16

+ func NewControlledShutdownResponse() ControlledShutdownResponse

+ func NewPtrControlledShutdownResponse() *ControlledShutdownResponse

+ func (*ControlledShutdownResponse) Key() int16

+ func (*ControlledShutdownResponse) MaxVersion() int16

+ func (v *ControlledShutdownResponse) AppendTo(dst []byte) []byte

+ func (v *ControlledShutdownResponse) Default()

+ func (v *ControlledShutdownResponse) GetVersion() int16

+ func (v *ControlledShutdownResponse) IsFlexible() bool

+ func (v *ControlledShutdownResponse) ReadFrom(src []byte) error

+ func (v *ControlledShutdownResponse) RequestKind() Request

+ func (v *ControlledShutdownResponse) SetVersion(version int16)

+ type ControlledShutdownResponsePartitionsRemaining struct

+ Partition int32

+ Topic string

+ UnknownTags Tags

+ func NewControlledShutdownResponsePartitionsRemaining() ControlledShutdownResponsePartitionsRemaining

+ func (v *ControlledShutdownResponsePartitionsRemaining) Default()

+ type CreateACLsRequest struct

+ Creations []CreateACLsRequestCreation

+ UnknownTags Tags

+ Version int16

+ func NewCreateACLsRequest() CreateACLsRequest

+ func NewPtrCreateACLsRequest() *CreateACLsRequest

+ func (*CreateACLsRequest) Key() int16

+ func (*CreateACLsRequest) MaxVersion() int16

+ func (v *CreateACLsRequest) AppendTo(dst []byte) []byte

+ func (v *CreateACLsRequest) Default()

+ func (v *CreateACLsRequest) GetVersion() int16

+ func (v *CreateACLsRequest) IsFlexible() bool

+ func (v *CreateACLsRequest) ReadFrom(src []byte) error

+ func (v *CreateACLsRequest) RequestWith(ctx context.Context, r Requestor) (*CreateACLsResponse, error)

+ func (v *CreateACLsRequest) ResponseKind() Response

+ func (v *CreateACLsRequest) SetVersion(version int16)

+ type CreateACLsRequestCreation struct

+ Host string

+ Operation ACLOperation

+ PermissionType ACLPermissionType

+ Principal string

+ ResourceName string

+ ResourcePatternType ACLResourcePatternType

+ ResourceType ACLResourceType

+ UnknownTags Tags

+ func NewCreateACLsRequestCreation() CreateACLsRequestCreation

+ func (v *CreateACLsRequestCreation) Default()

+ type CreateACLsResponse struct

+ Results []CreateACLsResponseResult

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewCreateACLsResponse() CreateACLsResponse

+ func NewPtrCreateACLsResponse() *CreateACLsResponse

+ func (*CreateACLsResponse) Key() int16

+ func (*CreateACLsResponse) MaxVersion() int16

+ func (v *CreateACLsResponse) AppendTo(dst []byte) []byte

+ func (v *CreateACLsResponse) Default()

+ func (v *CreateACLsResponse) GetVersion() int16

+ func (v *CreateACLsResponse) IsFlexible() bool

+ func (v *CreateACLsResponse) ReadFrom(src []byte) error

+ func (v *CreateACLsResponse) RequestKind() Request

+ func (v *CreateACLsResponse) SetVersion(version int16)

+ func (v *CreateACLsResponse) Throttle() (int32, bool)

+ type CreateACLsResponseResult struct

+ ErrorCode int16

+ ErrorMessage *string

+ UnknownTags Tags

+ func NewCreateACLsResponseResult() CreateACLsResponseResult

+ func (v *CreateACLsResponseResult) Default()

+ type CreateDelegationTokenRequest struct

+ MaxLifetimeMillis int64

+ Renewers []CreateDelegationTokenRequestRenewer

+ UnknownTags Tags

+ Version int16

+ func NewCreateDelegationTokenRequest() CreateDelegationTokenRequest

+ func NewPtrCreateDelegationTokenRequest() *CreateDelegationTokenRequest

+ func (*CreateDelegationTokenRequest) Key() int16

+ func (*CreateDelegationTokenRequest) MaxVersion() int16

+ func (v *CreateDelegationTokenRequest) AppendTo(dst []byte) []byte

+ func (v *CreateDelegationTokenRequest) Default()

+ func (v *CreateDelegationTokenRequest) GetVersion() int16

+ func (v *CreateDelegationTokenRequest) IsFlexible() bool

+ func (v *CreateDelegationTokenRequest) ReadFrom(src []byte) error

+ func (v *CreateDelegationTokenRequest) RequestWith(ctx context.Context, r Requestor) (*CreateDelegationTokenResponse, error)

+ func (v *CreateDelegationTokenRequest) ResponseKind() Response

+ func (v *CreateDelegationTokenRequest) SetVersion(version int16)

+ type CreateDelegationTokenRequestRenewer struct

+ PrincipalName string

+ PrincipalType string

+ UnknownTags Tags

+ func NewCreateDelegationTokenRequestRenewer() CreateDelegationTokenRequestRenewer

+ func (v *CreateDelegationTokenRequestRenewer) Default()

+ type CreateDelegationTokenResponse struct

+ ErrorCode int16

+ ExpiryTimestamp int64

+ HMAC []byte

+ IssueTimestamp int64

+ MaxTimestamp int64

+ PrincipalName string

+ PrincipalType string

+ ThrottleMillis int32

+ TokenID string

+ UnknownTags Tags

+ Version int16

+ func NewCreateDelegationTokenResponse() CreateDelegationTokenResponse

+ func NewPtrCreateDelegationTokenResponse() *CreateDelegationTokenResponse

+ func (*CreateDelegationTokenResponse) Key() int16

+ func (*CreateDelegationTokenResponse) MaxVersion() int16

+ func (v *CreateDelegationTokenResponse) AppendTo(dst []byte) []byte

+ func (v *CreateDelegationTokenResponse) Default()

+ func (v *CreateDelegationTokenResponse) GetVersion() int16

+ func (v *CreateDelegationTokenResponse) IsFlexible() bool

+ func (v *CreateDelegationTokenResponse) ReadFrom(src []byte) error

+ func (v *CreateDelegationTokenResponse) RequestKind() Request

+ func (v *CreateDelegationTokenResponse) SetVersion(version int16)

+ func (v *CreateDelegationTokenResponse) Throttle() (int32, bool)

+ type CreatePartitionsRequest struct

+ TimeoutMillis int32

+ Topics []CreatePartitionsRequestTopic

+ UnknownTags Tags

+ ValidateOnly bool

+ Version int16

+ func NewCreatePartitionsRequest() CreatePartitionsRequest

+ func NewPtrCreatePartitionsRequest() *CreatePartitionsRequest

+ func (*CreatePartitionsRequest) Key() int16

+ func (*CreatePartitionsRequest) MaxVersion() int16

+ func (v *CreatePartitionsRequest) AppendTo(dst []byte) []byte

+ func (v *CreatePartitionsRequest) Default()

+ func (v *CreatePartitionsRequest) GetVersion() int16

+ func (v *CreatePartitionsRequest) IsAdminRequest()

+ func (v *CreatePartitionsRequest) IsFlexible() bool

+ func (v *CreatePartitionsRequest) ReadFrom(src []byte) error

+ func (v *CreatePartitionsRequest) RequestWith(ctx context.Context, r Requestor) (*CreatePartitionsResponse, error)

+ func (v *CreatePartitionsRequest) ResponseKind() Response

+ func (v *CreatePartitionsRequest) SetVersion(version int16)

+ func (v *CreatePartitionsRequest) Timeout() int32

+ type CreatePartitionsRequestTopic struct

+ Assignment []CreatePartitionsRequestTopicAssignment

+ Count int32

+ Topic string

+ UnknownTags Tags

+ func NewCreatePartitionsRequestTopic() CreatePartitionsRequestTopic

+ func (v *CreatePartitionsRequestTopic) Default()

+ type CreatePartitionsRequestTopicAssignment struct

+ Replicas []int32

+ UnknownTags Tags

+ func NewCreatePartitionsRequestTopicAssignment() CreatePartitionsRequestTopicAssignment

+ func (v *CreatePartitionsRequestTopicAssignment) Default()

+ type CreatePartitionsResponse struct

+ ThrottleMillis int32

+ Topics []CreatePartitionsResponseTopic

+ UnknownTags Tags

+ Version int16

+ func NewCreatePartitionsResponse() CreatePartitionsResponse

+ func NewPtrCreatePartitionsResponse() *CreatePartitionsResponse

+ func (*CreatePartitionsResponse) Key() int16

+ func (*CreatePartitionsResponse) MaxVersion() int16

+ func (v *CreatePartitionsResponse) AppendTo(dst []byte) []byte

+ func (v *CreatePartitionsResponse) Default()

+ func (v *CreatePartitionsResponse) GetVersion() int16

+ func (v *CreatePartitionsResponse) IsFlexible() bool

+ func (v *CreatePartitionsResponse) ReadFrom(src []byte) error

+ func (v *CreatePartitionsResponse) RequestKind() Request

+ func (v *CreatePartitionsResponse) SetVersion(version int16)

+ func (v *CreatePartitionsResponse) Throttle() (int32, bool)

+ type CreatePartitionsResponseTopic struct

+ ErrorCode int16

+ ErrorMessage *string

+ Topic string

+ UnknownTags Tags

+ func NewCreatePartitionsResponseTopic() CreatePartitionsResponseTopic

+ func (v *CreatePartitionsResponseTopic) Default()

+ type CreateTopicsRequest struct

+ TimeoutMillis int32

+ Topics []CreateTopicsRequestTopic

+ UnknownTags Tags

+ ValidateOnly bool

+ Version int16

+ func NewCreateTopicsRequest() CreateTopicsRequest

+ func NewPtrCreateTopicsRequest() *CreateTopicsRequest

+ func (*CreateTopicsRequest) Key() int16

+ func (*CreateTopicsRequest) MaxVersion() int16

+ func (v *CreateTopicsRequest) AppendTo(dst []byte) []byte

+ func (v *CreateTopicsRequest) Default()

+ func (v *CreateTopicsRequest) GetVersion() int16

+ func (v *CreateTopicsRequest) IsAdminRequest()

+ func (v *CreateTopicsRequest) IsFlexible() bool

+ func (v *CreateTopicsRequest) ReadFrom(src []byte) error

+ func (v *CreateTopicsRequest) RequestWith(ctx context.Context, r Requestor) (*CreateTopicsResponse, error)

+ func (v *CreateTopicsRequest) ResponseKind() Response

+ func (v *CreateTopicsRequest) SetVersion(version int16)

+ func (v *CreateTopicsRequest) Timeout() int32

+ type CreateTopicsRequestTopic struct

+ Configs []CreateTopicsRequestTopicConfig

+ NumPartitions int32

+ ReplicaAssignment []CreateTopicsRequestTopicReplicaAssignment

+ ReplicationFactor int16

+ Topic string

+ UnknownTags Tags

+ func NewCreateTopicsRequestTopic() CreateTopicsRequestTopic

+ func (v *CreateTopicsRequestTopic) Default()

+ type CreateTopicsRequestTopicConfig struct

+ Name string

+ UnknownTags Tags

+ Value *string

+ func NewCreateTopicsRequestTopicConfig() CreateTopicsRequestTopicConfig

+ func (v *CreateTopicsRequestTopicConfig) Default()

+ type CreateTopicsRequestTopicReplicaAssignment struct

+ Partition int32

+ Replicas []int32

+ UnknownTags Tags

+ func NewCreateTopicsRequestTopicReplicaAssignment() CreateTopicsRequestTopicReplicaAssignment

+ func (v *CreateTopicsRequestTopicReplicaAssignment) Default()

+ type CreateTopicsResponse struct

+ ThrottleMillis int32

+ Topics []CreateTopicsResponseTopic

+ UnknownTags Tags

+ Version int16

+ func NewCreateTopicsResponse() CreateTopicsResponse

+ func NewPtrCreateTopicsResponse() *CreateTopicsResponse

+ func (*CreateTopicsResponse) Key() int16

+ func (*CreateTopicsResponse) MaxVersion() int16

+ func (v *CreateTopicsResponse) AppendTo(dst []byte) []byte

+ func (v *CreateTopicsResponse) Default()

+ func (v *CreateTopicsResponse) GetVersion() int16

+ func (v *CreateTopicsResponse) IsFlexible() bool

+ func (v *CreateTopicsResponse) ReadFrom(src []byte) error

+ func (v *CreateTopicsResponse) RequestKind() Request

+ func (v *CreateTopicsResponse) SetVersion(version int16)

+ func (v *CreateTopicsResponse) Throttle() (int32, bool)

+ type CreateTopicsResponseTopic struct

+ ConfigErrorCode int16

+ Configs []CreateTopicsResponseTopicConfig

+ ErrorCode int16

+ ErrorMessage *string

+ NumPartitions int32

+ ReplicationFactor int16

+ Topic string

+ TopicID [16]byte

+ UnknownTags Tags

+ func NewCreateTopicsResponseTopic() CreateTopicsResponseTopic

+ func (v *CreateTopicsResponseTopic) Default()

+ type CreateTopicsResponseTopicConfig struct

+ IsSensitive bool

+ Name string

+ ReadOnly bool

+ Source int8

+ UnknownTags Tags

+ Value *string

+ func NewCreateTopicsResponseTopicConfig() CreateTopicsResponseTopicConfig

+ func (v *CreateTopicsResponseTopicConfig) Default()

+ type DefaultPrincipalData struct

+ Name string

+ TokenAuthenticated bool

+ Type string

+ UnknownTags Tags

+ Version int16

+ func NewDefaultPrincipalData() DefaultPrincipalData

+ func (v *DefaultPrincipalData) AppendTo(dst []byte) []byte

+ func (v *DefaultPrincipalData) Default()

+ func (v *DefaultPrincipalData) IsFlexible() bool

+ func (v *DefaultPrincipalData) ReadFrom(src []byte) error

+ type DeleteACLsRequest struct

+ Filters []DeleteACLsRequestFilter

+ UnknownTags Tags

+ Version int16

+ func NewDeleteACLsRequest() DeleteACLsRequest

+ func NewPtrDeleteACLsRequest() *DeleteACLsRequest

+ func (*DeleteACLsRequest) Key() int16

+ func (*DeleteACLsRequest) MaxVersion() int16

+ func (v *DeleteACLsRequest) AppendTo(dst []byte) []byte

+ func (v *DeleteACLsRequest) Default()

+ func (v *DeleteACLsRequest) GetVersion() int16

+ func (v *DeleteACLsRequest) IsFlexible() bool

+ func (v *DeleteACLsRequest) ReadFrom(src []byte) error

+ func (v *DeleteACLsRequest) RequestWith(ctx context.Context, r Requestor) (*DeleteACLsResponse, error)

+ func (v *DeleteACLsRequest) ResponseKind() Response

+ func (v *DeleteACLsRequest) SetVersion(version int16)

+ type DeleteACLsRequestFilter struct

+ Host *string

+ Operation ACLOperation

+ PermissionType ACLPermissionType

+ Principal *string

+ ResourceName *string

+ ResourcePatternType ACLResourcePatternType

+ ResourceType ACLResourceType

+ UnknownTags Tags

+ func NewDeleteACLsRequestFilter() DeleteACLsRequestFilter

+ func (v *DeleteACLsRequestFilter) Default()

+ type DeleteACLsResponse struct

+ Results []DeleteACLsResponseResult

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewDeleteACLsResponse() DeleteACLsResponse

+ func NewPtrDeleteACLsResponse() *DeleteACLsResponse

+ func (*DeleteACLsResponse) Key() int16

+ func (*DeleteACLsResponse) MaxVersion() int16

+ func (v *DeleteACLsResponse) AppendTo(dst []byte) []byte

+ func (v *DeleteACLsResponse) Default()

+ func (v *DeleteACLsResponse) GetVersion() int16

+ func (v *DeleteACLsResponse) IsFlexible() bool

+ func (v *DeleteACLsResponse) ReadFrom(src []byte) error

+ func (v *DeleteACLsResponse) RequestKind() Request

+ func (v *DeleteACLsResponse) SetVersion(version int16)

+ func (v *DeleteACLsResponse) Throttle() (int32, bool)

+ type DeleteACLsResponseResult struct

+ ErrorCode int16

+ ErrorMessage *string

+ MatchingACLs []DeleteACLsResponseResultMatchingACL

+ UnknownTags Tags

+ func NewDeleteACLsResponseResult() DeleteACLsResponseResult

+ func (v *DeleteACLsResponseResult) Default()

+ type DeleteACLsResponseResultMatchingACL struct

+ ErrorCode int16

+ ErrorMessage *string

+ Host string

+ Operation ACLOperation

+ PermissionType ACLPermissionType

+ Principal string

+ ResourceName string

+ ResourcePatternType ACLResourcePatternType

+ ResourceType ACLResourceType

+ UnknownTags Tags

+ func NewDeleteACLsResponseResultMatchingACL() DeleteACLsResponseResultMatchingACL

+ func (v *DeleteACLsResponseResultMatchingACL) Default()

+ type DeleteGroupsRequest struct

+ Groups []string

+ UnknownTags Tags

+ Version int16

+ func NewDeleteGroupsRequest() DeleteGroupsRequest

+ func NewPtrDeleteGroupsRequest() *DeleteGroupsRequest

+ func (*DeleteGroupsRequest) Key() int16

+ func (*DeleteGroupsRequest) MaxVersion() int16

+ func (v *DeleteGroupsRequest) AppendTo(dst []byte) []byte

+ func (v *DeleteGroupsRequest) Default()

+ func (v *DeleteGroupsRequest) GetVersion() int16

+ func (v *DeleteGroupsRequest) IsFlexible() bool

+ func (v *DeleteGroupsRequest) IsGroupCoordinatorRequest()

+ func (v *DeleteGroupsRequest) ReadFrom(src []byte) error

+ func (v *DeleteGroupsRequest) RequestWith(ctx context.Context, r Requestor) (*DeleteGroupsResponse, error)

+ func (v *DeleteGroupsRequest) ResponseKind() Response

+ func (v *DeleteGroupsRequest) SetVersion(version int16)

+ type DeleteGroupsResponse struct

+ Groups []DeleteGroupsResponseGroup

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewDeleteGroupsResponse() DeleteGroupsResponse

+ func NewPtrDeleteGroupsResponse() *DeleteGroupsResponse

+ func (*DeleteGroupsResponse) Key() int16

+ func (*DeleteGroupsResponse) MaxVersion() int16

+ func (v *DeleteGroupsResponse) AppendTo(dst []byte) []byte

+ func (v *DeleteGroupsResponse) Default()

+ func (v *DeleteGroupsResponse) GetVersion() int16

+ func (v *DeleteGroupsResponse) IsFlexible() bool

+ func (v *DeleteGroupsResponse) ReadFrom(src []byte) error

+ func (v *DeleteGroupsResponse) RequestKind() Request

+ func (v *DeleteGroupsResponse) SetVersion(version int16)

+ func (v *DeleteGroupsResponse) Throttle() (int32, bool)

+ type DeleteGroupsResponseGroup struct

+ ErrorCode int16

+ Group string

+ UnknownTags Tags

+ func NewDeleteGroupsResponseGroup() DeleteGroupsResponseGroup

+ func (v *DeleteGroupsResponseGroup) Default()

+ type DeleteRecordsRequest struct

+ TimeoutMillis int32

+ Topics []DeleteRecordsRequestTopic

+ UnknownTags Tags

+ Version int16

+ func NewDeleteRecordsRequest() DeleteRecordsRequest

+ func NewPtrDeleteRecordsRequest() *DeleteRecordsRequest

+ func (*DeleteRecordsRequest) Key() int16

+ func (*DeleteRecordsRequest) MaxVersion() int16

+ func (v *DeleteRecordsRequest) AppendTo(dst []byte) []byte

+ func (v *DeleteRecordsRequest) Default()

+ func (v *DeleteRecordsRequest) GetVersion() int16

+ func (v *DeleteRecordsRequest) IsFlexible() bool

+ func (v *DeleteRecordsRequest) ReadFrom(src []byte) error

+ func (v *DeleteRecordsRequest) RequestWith(ctx context.Context, r Requestor) (*DeleteRecordsResponse, error)

+ func (v *DeleteRecordsRequest) ResponseKind() Response

+ func (v *DeleteRecordsRequest) SetVersion(version int16)

+ func (v *DeleteRecordsRequest) Timeout() int32

+ type DeleteRecordsRequestTopic struct

+ Partitions []DeleteRecordsRequestTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewDeleteRecordsRequestTopic() DeleteRecordsRequestTopic

+ func (v *DeleteRecordsRequestTopic) Default()

+ type DeleteRecordsRequestTopicPartition struct

+ Offset int64

+ Partition int32

+ UnknownTags Tags

+ func NewDeleteRecordsRequestTopicPartition() DeleteRecordsRequestTopicPartition

+ func (v *DeleteRecordsRequestTopicPartition) Default()

+ type DeleteRecordsResponse struct

+ ThrottleMillis int32

+ Topics []DeleteRecordsResponseTopic

+ UnknownTags Tags

+ Version int16

+ func NewDeleteRecordsResponse() DeleteRecordsResponse

+ func NewPtrDeleteRecordsResponse() *DeleteRecordsResponse

+ func (*DeleteRecordsResponse) Key() int16

+ func (*DeleteRecordsResponse) MaxVersion() int16

+ func (v *DeleteRecordsResponse) AppendTo(dst []byte) []byte

+ func (v *DeleteRecordsResponse) Default()

+ func (v *DeleteRecordsResponse) GetVersion() int16

+ func (v *DeleteRecordsResponse) IsFlexible() bool

+ func (v *DeleteRecordsResponse) ReadFrom(src []byte) error

+ func (v *DeleteRecordsResponse) RequestKind() Request

+ func (v *DeleteRecordsResponse) SetVersion(version int16)

+ func (v *DeleteRecordsResponse) Throttle() (int32, bool)

+ type DeleteRecordsResponseTopic struct

+ Partitions []DeleteRecordsResponseTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewDeleteRecordsResponseTopic() DeleteRecordsResponseTopic

+ func (v *DeleteRecordsResponseTopic) Default()

+ type DeleteRecordsResponseTopicPartition struct

+ ErrorCode int16

+ LowWatermark int64

+ Partition int32

+ UnknownTags Tags

+ func NewDeleteRecordsResponseTopicPartition() DeleteRecordsResponseTopicPartition

+ func (v *DeleteRecordsResponseTopicPartition) Default()

+ type DeleteTopicsRequest struct

+ TimeoutMillis int32

+ TopicNames []string

+ Topics []DeleteTopicsRequestTopic

+ UnknownTags Tags

+ Version int16

+ func NewDeleteTopicsRequest() DeleteTopicsRequest

+ func NewPtrDeleteTopicsRequest() *DeleteTopicsRequest

+ func (*DeleteTopicsRequest) Key() int16

+ func (*DeleteTopicsRequest) MaxVersion() int16

+ func (v *DeleteTopicsRequest) AppendTo(dst []byte) []byte

+ func (v *DeleteTopicsRequest) Default()

+ func (v *DeleteTopicsRequest) GetVersion() int16

+ func (v *DeleteTopicsRequest) IsAdminRequest()

+ func (v *DeleteTopicsRequest) IsFlexible() bool

+ func (v *DeleteTopicsRequest) ReadFrom(src []byte) error

+ func (v *DeleteTopicsRequest) RequestWith(ctx context.Context, r Requestor) (*DeleteTopicsResponse, error)

+ func (v *DeleteTopicsRequest) ResponseKind() Response

+ func (v *DeleteTopicsRequest) SetVersion(version int16)

+ func (v *DeleteTopicsRequest) Timeout() int32

+ type DeleteTopicsRequestTopic struct

+ Topic *string

+ TopicID [16]byte

+ UnknownTags Tags

+ func NewDeleteTopicsRequestTopic() DeleteTopicsRequestTopic

+ func (v *DeleteTopicsRequestTopic) Default()

+ type DeleteTopicsResponse struct

+ ThrottleMillis int32

+ Topics []DeleteTopicsResponseTopic

+ UnknownTags Tags

+ Version int16

+ func NewDeleteTopicsResponse() DeleteTopicsResponse

+ func NewPtrDeleteTopicsResponse() *DeleteTopicsResponse

+ func (*DeleteTopicsResponse) Key() int16

+ func (*DeleteTopicsResponse) MaxVersion() int16

+ func (v *DeleteTopicsResponse) AppendTo(dst []byte) []byte

+ func (v *DeleteTopicsResponse) Default()

+ func (v *DeleteTopicsResponse) GetVersion() int16

+ func (v *DeleteTopicsResponse) IsFlexible() bool

+ func (v *DeleteTopicsResponse) ReadFrom(src []byte) error

+ func (v *DeleteTopicsResponse) RequestKind() Request

+ func (v *DeleteTopicsResponse) SetVersion(version int16)

+ func (v *DeleteTopicsResponse) Throttle() (int32, bool)

+ type DeleteTopicsResponseTopic struct

+ ErrorCode int16

+ ErrorMessage *string

+ Topic *string

+ TopicID [16]byte

+ UnknownTags Tags

+ func NewDeleteTopicsResponseTopic() DeleteTopicsResponseTopic

+ func (v *DeleteTopicsResponseTopic) Default()

+ type DescribeACLsRequest struct

+ Host *string

+ Operation ACLOperation

+ PermissionType ACLPermissionType

+ Principal *string

+ ResourceName *string

+ ResourcePatternType ACLResourcePatternType

+ ResourceType ACLResourceType

+ UnknownTags Tags

+ Version int16

+ func NewDescribeACLsRequest() DescribeACLsRequest

+ func NewPtrDescribeACLsRequest() *DescribeACLsRequest

+ func (*DescribeACLsRequest) Key() int16

+ func (*DescribeACLsRequest) MaxVersion() int16

+ func (v *DescribeACLsRequest) AppendTo(dst []byte) []byte

+ func (v *DescribeACLsRequest) Default()

+ func (v *DescribeACLsRequest) GetVersion() int16

+ func (v *DescribeACLsRequest) IsFlexible() bool

+ func (v *DescribeACLsRequest) ReadFrom(src []byte) error

+ func (v *DescribeACLsRequest) RequestWith(ctx context.Context, r Requestor) (*DescribeACLsResponse, error)

+ func (v *DescribeACLsRequest) ResponseKind() Response

+ func (v *DescribeACLsRequest) SetVersion(version int16)

+ type DescribeACLsResponse struct

+ ErrorCode int16

+ ErrorMessage *string

+ Resources []DescribeACLsResponseResource

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewDescribeACLsResponse() DescribeACLsResponse

+ func NewPtrDescribeACLsResponse() *DescribeACLsResponse

+ func (*DescribeACLsResponse) Key() int16

+ func (*DescribeACLsResponse) MaxVersion() int16

+ func (v *DescribeACLsResponse) AppendTo(dst []byte) []byte

+ func (v *DescribeACLsResponse) Default()

+ func (v *DescribeACLsResponse) GetVersion() int16

+ func (v *DescribeACLsResponse) IsFlexible() bool

+ func (v *DescribeACLsResponse) ReadFrom(src []byte) error

+ func (v *DescribeACLsResponse) RequestKind() Request

+ func (v *DescribeACLsResponse) SetVersion(version int16)

+ func (v *DescribeACLsResponse) Throttle() (int32, bool)

+ type DescribeACLsResponseResource struct

+ ACLs []DescribeACLsResponseResourceACL

+ ResourceName string

+ ResourcePatternType ACLResourcePatternType

+ ResourceType ACLResourceType

+ UnknownTags Tags

+ func NewDescribeACLsResponseResource() DescribeACLsResponseResource

+ func (v *DescribeACLsResponseResource) Default()

+ type DescribeACLsResponseResourceACL struct

+ Host string

+ Operation ACLOperation

+ PermissionType ACLPermissionType

+ Principal string

+ UnknownTags Tags

+ func NewDescribeACLsResponseResourceACL() DescribeACLsResponseResourceACL

+ func (v *DescribeACLsResponseResourceACL) Default()

+ type DescribeClientQuotasRequest struct

+ Components []DescribeClientQuotasRequestComponent

+ Strict bool

+ UnknownTags Tags

+ Version int16

+ func NewDescribeClientQuotasRequest() DescribeClientQuotasRequest

+ func NewPtrDescribeClientQuotasRequest() *DescribeClientQuotasRequest

+ func (*DescribeClientQuotasRequest) Key() int16

+ func (*DescribeClientQuotasRequest) MaxVersion() int16

+ func (v *DescribeClientQuotasRequest) AppendTo(dst []byte) []byte

+ func (v *DescribeClientQuotasRequest) Default()

+ func (v *DescribeClientQuotasRequest) GetVersion() int16

+ func (v *DescribeClientQuotasRequest) IsFlexible() bool

+ func (v *DescribeClientQuotasRequest) ReadFrom(src []byte) error

+ func (v *DescribeClientQuotasRequest) RequestWith(ctx context.Context, r Requestor) (*DescribeClientQuotasResponse, error)

+ func (v *DescribeClientQuotasRequest) ResponseKind() Response

+ func (v *DescribeClientQuotasRequest) SetVersion(version int16)

+ type DescribeClientQuotasRequestComponent struct

+ EntityType string

+ Match *string

+ MatchType QuotasMatchType

+ UnknownTags Tags

+ func NewDescribeClientQuotasRequestComponent() DescribeClientQuotasRequestComponent

+ func (v *DescribeClientQuotasRequestComponent) Default()

+ type DescribeClientQuotasResponse struct

+ Entries []DescribeClientQuotasResponseEntry

+ ErrorCode int16

+ ErrorMessage *string

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewDescribeClientQuotasResponse() DescribeClientQuotasResponse

+ func NewPtrDescribeClientQuotasResponse() *DescribeClientQuotasResponse

+ func (*DescribeClientQuotasResponse) Key() int16

+ func (*DescribeClientQuotasResponse) MaxVersion() int16

+ func (v *DescribeClientQuotasResponse) AppendTo(dst []byte) []byte

+ func (v *DescribeClientQuotasResponse) Default()

+ func (v *DescribeClientQuotasResponse) GetVersion() int16

+ func (v *DescribeClientQuotasResponse) IsFlexible() bool

+ func (v *DescribeClientQuotasResponse) ReadFrom(src []byte) error

+ func (v *DescribeClientQuotasResponse) RequestKind() Request

+ func (v *DescribeClientQuotasResponse) SetVersion(version int16)

+ func (v *DescribeClientQuotasResponse) Throttle() (int32, bool)

+ type DescribeClientQuotasResponseEntry struct

+ Entity []DescribeClientQuotasResponseEntryEntity

+ UnknownTags Tags

+ Values []DescribeClientQuotasResponseEntryValue

+ func NewDescribeClientQuotasResponseEntry() DescribeClientQuotasResponseEntry

+ func (v *DescribeClientQuotasResponseEntry) Default()

+ type DescribeClientQuotasResponseEntryEntity struct

+ Name *string

+ Type string

+ UnknownTags Tags

+ func NewDescribeClientQuotasResponseEntryEntity() DescribeClientQuotasResponseEntryEntity

+ func (v *DescribeClientQuotasResponseEntryEntity) Default()

+ type DescribeClientQuotasResponseEntryValue struct

+ Key string

+ UnknownTags Tags

+ Value float64

+ func NewDescribeClientQuotasResponseEntryValue() DescribeClientQuotasResponseEntryValue

+ func (v *DescribeClientQuotasResponseEntryValue) Default()

+ type DescribeClusterRequest struct

+ IncludeClusterAuthorizedOperations bool

+ UnknownTags Tags

+ Version int16

+ func NewDescribeClusterRequest() DescribeClusterRequest

+ func NewPtrDescribeClusterRequest() *DescribeClusterRequest

+ func (*DescribeClusterRequest) Key() int16

+ func (*DescribeClusterRequest) MaxVersion() int16

+ func (v *DescribeClusterRequest) AppendTo(dst []byte) []byte

+ func (v *DescribeClusterRequest) Default()

+ func (v *DescribeClusterRequest) GetVersion() int16

+ func (v *DescribeClusterRequest) IsFlexible() bool

+ func (v *DescribeClusterRequest) ReadFrom(src []byte) error

+ func (v *DescribeClusterRequest) RequestWith(ctx context.Context, r Requestor) (*DescribeClusterResponse, error)

+ func (v *DescribeClusterRequest) ResponseKind() Response

+ func (v *DescribeClusterRequest) SetVersion(version int16)

+ type DescribeClusterResponse struct

+ Brokers []DescribeClusterResponseBroker

+ ClusterAuthorizedOperations int32

+ ClusterID string

+ ControllerID int32

+ ErrorCode int16

+ ErrorMessage *string

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewDescribeClusterResponse() DescribeClusterResponse

+ func NewPtrDescribeClusterResponse() *DescribeClusterResponse

+ func (*DescribeClusterResponse) Key() int16

+ func (*DescribeClusterResponse) MaxVersion() int16

+ func (v *DescribeClusterResponse) AppendTo(dst []byte) []byte

+ func (v *DescribeClusterResponse) Default()

+ func (v *DescribeClusterResponse) GetVersion() int16

+ func (v *DescribeClusterResponse) IsFlexible() bool

+ func (v *DescribeClusterResponse) ReadFrom(src []byte) error

+ func (v *DescribeClusterResponse) RequestKind() Request

+ func (v *DescribeClusterResponse) SetVersion(version int16)

+ func (v *DescribeClusterResponse) Throttle() (int32, bool)

+ type DescribeClusterResponseBroker struct

+ Host string

+ NodeID int32

+ Port int32

+ Rack *string

+ UnknownTags Tags

+ func NewDescribeClusterResponseBroker() DescribeClusterResponseBroker

+ func (v *DescribeClusterResponseBroker) Default()

+ type DescribeConfigsRequest struct

+ IncludeDocumentation bool

+ IncludeSynonyms bool

+ Resources []DescribeConfigsRequestResource

+ UnknownTags Tags

+ Version int16

+ func NewDescribeConfigsRequest() DescribeConfigsRequest

+ func NewPtrDescribeConfigsRequest() *DescribeConfigsRequest

+ func (*DescribeConfigsRequest) Key() int16

+ func (*DescribeConfigsRequest) MaxVersion() int16

+ func (v *DescribeConfigsRequest) AppendTo(dst []byte) []byte

+ func (v *DescribeConfigsRequest) Default()

+ func (v *DescribeConfigsRequest) GetVersion() int16

+ func (v *DescribeConfigsRequest) IsFlexible() bool

+ func (v *DescribeConfigsRequest) ReadFrom(src []byte) error

+ func (v *DescribeConfigsRequest) RequestWith(ctx context.Context, r Requestor) (*DescribeConfigsResponse, error)

+ func (v *DescribeConfigsRequest) ResponseKind() Response

+ func (v *DescribeConfigsRequest) SetVersion(version int16)

+ type DescribeConfigsRequestResource struct

+ ConfigNames []string

+ ResourceName string

+ ResourceType ConfigResourceType

+ UnknownTags Tags

+ func NewDescribeConfigsRequestResource() DescribeConfigsRequestResource

+ func (v *DescribeConfigsRequestResource) Default()

+ type DescribeConfigsResponse struct

+ Resources []DescribeConfigsResponseResource

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewDescribeConfigsResponse() DescribeConfigsResponse

+ func NewPtrDescribeConfigsResponse() *DescribeConfigsResponse

+ func (*DescribeConfigsResponse) Key() int16

+ func (*DescribeConfigsResponse) MaxVersion() int16

+ func (v *DescribeConfigsResponse) AppendTo(dst []byte) []byte

+ func (v *DescribeConfigsResponse) Default()

+ func (v *DescribeConfigsResponse) GetVersion() int16

+ func (v *DescribeConfigsResponse) IsFlexible() bool

+ func (v *DescribeConfigsResponse) ReadFrom(src []byte) error

+ func (v *DescribeConfigsResponse) RequestKind() Request

+ func (v *DescribeConfigsResponse) SetVersion(version int16)

+ func (v *DescribeConfigsResponse) Throttle() (int32, bool)

+ type DescribeConfigsResponseResource struct

+ Configs []DescribeConfigsResponseResourceConfig

+ ErrorCode int16

+ ErrorMessage *string

+ ResourceName string

+ ResourceType ConfigResourceType

+ UnknownTags Tags

+ func NewDescribeConfigsResponseResource() DescribeConfigsResponseResource

+ func (v *DescribeConfigsResponseResource) Default()

+ type DescribeConfigsResponseResourceConfig struct

+ ConfigSynonyms []DescribeConfigsResponseResourceConfigConfigSynonym

+ ConfigType ConfigType

+ Documentation *string

+ IsDefault bool

+ IsSensitive bool

+ Name string

+ ReadOnly bool

+ Source ConfigSource

+ UnknownTags Tags

+ Value *string

+ func NewDescribeConfigsResponseResourceConfig() DescribeConfigsResponseResourceConfig

+ func (v *DescribeConfigsResponseResourceConfig) Default()

+ type DescribeConfigsResponseResourceConfigConfigSynonym struct

+ Name string

+ Source ConfigSource

+ UnknownTags Tags

+ Value *string

+ func NewDescribeConfigsResponseResourceConfigConfigSynonym() DescribeConfigsResponseResourceConfigConfigSynonym

+ func (v *DescribeConfigsResponseResourceConfigConfigSynonym) Default()

+ type DescribeDelegationTokenRequest struct

+ Owners []DescribeDelegationTokenRequestOwner

+ UnknownTags Tags

+ Version int16

+ func NewDescribeDelegationTokenRequest() DescribeDelegationTokenRequest

+ func NewPtrDescribeDelegationTokenRequest() *DescribeDelegationTokenRequest

+ func (*DescribeDelegationTokenRequest) Key() int16

+ func (*DescribeDelegationTokenRequest) MaxVersion() int16

+ func (v *DescribeDelegationTokenRequest) AppendTo(dst []byte) []byte

+ func (v *DescribeDelegationTokenRequest) Default()

+ func (v *DescribeDelegationTokenRequest) GetVersion() int16

+ func (v *DescribeDelegationTokenRequest) IsFlexible() bool

+ func (v *DescribeDelegationTokenRequest) ReadFrom(src []byte) error

+ func (v *DescribeDelegationTokenRequest) RequestWith(ctx context.Context, r Requestor) (*DescribeDelegationTokenResponse, error)

+ func (v *DescribeDelegationTokenRequest) ResponseKind() Response

+ func (v *DescribeDelegationTokenRequest) SetVersion(version int16)

+ type DescribeDelegationTokenRequestOwner struct

+ PrincipalName string

+ PrincipalType string

+ UnknownTags Tags

+ func NewDescribeDelegationTokenRequestOwner() DescribeDelegationTokenRequestOwner

+ func (v *DescribeDelegationTokenRequestOwner) Default()

+ type DescribeDelegationTokenResponse struct

+ ErrorCode int16

+ ThrottleMillis int32

+ TokenDetails []DescribeDelegationTokenResponseTokenDetail

+ UnknownTags Tags

+ Version int16

+ func NewDescribeDelegationTokenResponse() DescribeDelegationTokenResponse

+ func NewPtrDescribeDelegationTokenResponse() *DescribeDelegationTokenResponse

+ func (*DescribeDelegationTokenResponse) Key() int16

+ func (*DescribeDelegationTokenResponse) MaxVersion() int16

+ func (v *DescribeDelegationTokenResponse) AppendTo(dst []byte) []byte

+ func (v *DescribeDelegationTokenResponse) Default()

+ func (v *DescribeDelegationTokenResponse) GetVersion() int16

+ func (v *DescribeDelegationTokenResponse) IsFlexible() bool

+ func (v *DescribeDelegationTokenResponse) ReadFrom(src []byte) error

+ func (v *DescribeDelegationTokenResponse) RequestKind() Request

+ func (v *DescribeDelegationTokenResponse) SetVersion(version int16)

+ func (v *DescribeDelegationTokenResponse) Throttle() (int32, bool)

+ type DescribeDelegationTokenResponseTokenDetail struct

+ ExpiryTimestamp int64

+ HMAC []byte

+ IssueTimestamp int64

+ MaxTimestamp int64

+ PrincipalName string

+ PrincipalType string

+ Renewers []DescribeDelegationTokenResponseTokenDetailRenewer

+ TokenID string

+ UnknownTags Tags

+ func NewDescribeDelegationTokenResponseTokenDetail() DescribeDelegationTokenResponseTokenDetail

+ func (v *DescribeDelegationTokenResponseTokenDetail) Default()

+ type DescribeDelegationTokenResponseTokenDetailRenewer struct

+ PrincipalName string

+ PrincipalType string

+ UnknownTags Tags

+ func NewDescribeDelegationTokenResponseTokenDetailRenewer() DescribeDelegationTokenResponseTokenDetailRenewer

+ func (v *DescribeDelegationTokenResponseTokenDetailRenewer) Default()

+ type DescribeGroupsRequest struct

+ Groups []string

+ IncludeAuthorizedOperations bool

+ UnknownTags Tags

+ Version int16

+ func NewDescribeGroupsRequest() DescribeGroupsRequest

+ func NewPtrDescribeGroupsRequest() *DescribeGroupsRequest

+ func (*DescribeGroupsRequest) Key() int16

+ func (*DescribeGroupsRequest) MaxVersion() int16

+ func (v *DescribeGroupsRequest) AppendTo(dst []byte) []byte

+ func (v *DescribeGroupsRequest) Default()

+ func (v *DescribeGroupsRequest) GetVersion() int16

+ func (v *DescribeGroupsRequest) IsFlexible() bool

+ func (v *DescribeGroupsRequest) IsGroupCoordinatorRequest()

+ func (v *DescribeGroupsRequest) ReadFrom(src []byte) error

+ func (v *DescribeGroupsRequest) RequestWith(ctx context.Context, r Requestor) (*DescribeGroupsResponse, error)

+ func (v *DescribeGroupsRequest) ResponseKind() Response

+ func (v *DescribeGroupsRequest) SetVersion(version int16)

+ type DescribeGroupsResponse struct

+ Groups []DescribeGroupsResponseGroup

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewDescribeGroupsResponse() DescribeGroupsResponse

+ func NewPtrDescribeGroupsResponse() *DescribeGroupsResponse

+ func (*DescribeGroupsResponse) Key() int16

+ func (*DescribeGroupsResponse) MaxVersion() int16

+ func (v *DescribeGroupsResponse) AppendTo(dst []byte) []byte

+ func (v *DescribeGroupsResponse) Default()

+ func (v *DescribeGroupsResponse) GetVersion() int16

+ func (v *DescribeGroupsResponse) IsFlexible() bool

+ func (v *DescribeGroupsResponse) ReadFrom(src []byte) error

+ func (v *DescribeGroupsResponse) RequestKind() Request

+ func (v *DescribeGroupsResponse) SetVersion(version int16)

+ func (v *DescribeGroupsResponse) Throttle() (int32, bool)

+ type DescribeGroupsResponseGroup struct

+ AuthorizedOperations int32

+ ErrorCode int16

+ Group string

+ Members []DescribeGroupsResponseGroupMember

+ Protocol string

+ ProtocolType string

+ State string

+ UnknownTags Tags

+ func NewDescribeGroupsResponseGroup() DescribeGroupsResponseGroup

+ func (v *DescribeGroupsResponseGroup) Default()

+ type DescribeGroupsResponseGroupMember struct

+ ClientHost string

+ ClientID string

+ InstanceID *string

+ MemberAssignment []byte

+ MemberID string

+ ProtocolMetadata []byte

+ UnknownTags Tags

+ func NewDescribeGroupsResponseGroupMember() DescribeGroupsResponseGroupMember

+ func (v *DescribeGroupsResponseGroupMember) Default()

+ type DescribeLogDirsRequest struct

+ Topics []DescribeLogDirsRequestTopic

+ UnknownTags Tags

+ Version int16

+ func NewDescribeLogDirsRequest() DescribeLogDirsRequest

+ func NewPtrDescribeLogDirsRequest() *DescribeLogDirsRequest

+ func (*DescribeLogDirsRequest) Key() int16

+ func (*DescribeLogDirsRequest) MaxVersion() int16

+ func (v *DescribeLogDirsRequest) AppendTo(dst []byte) []byte

+ func (v *DescribeLogDirsRequest) Default()

+ func (v *DescribeLogDirsRequest) GetVersion() int16

+ func (v *DescribeLogDirsRequest) IsFlexible() bool

+ func (v *DescribeLogDirsRequest) ReadFrom(src []byte) error

+ func (v *DescribeLogDirsRequest) RequestWith(ctx context.Context, r Requestor) (*DescribeLogDirsResponse, error)

+ func (v *DescribeLogDirsRequest) ResponseKind() Response

+ func (v *DescribeLogDirsRequest) SetVersion(version int16)

+ type DescribeLogDirsRequestTopic struct

+ Partitions []int32

+ Topic string

+ UnknownTags Tags

+ func NewDescribeLogDirsRequestTopic() DescribeLogDirsRequestTopic

+ func (v *DescribeLogDirsRequestTopic) Default()

+ type DescribeLogDirsResponse struct

+ Dirs []DescribeLogDirsResponseDir

+ ErrorCode int16

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewDescribeLogDirsResponse() DescribeLogDirsResponse

+ func NewPtrDescribeLogDirsResponse() *DescribeLogDirsResponse

+ func (*DescribeLogDirsResponse) Key() int16

+ func (*DescribeLogDirsResponse) MaxVersion() int16

+ func (v *DescribeLogDirsResponse) AppendTo(dst []byte) []byte

+ func (v *DescribeLogDirsResponse) Default()

+ func (v *DescribeLogDirsResponse) GetVersion() int16

+ func (v *DescribeLogDirsResponse) IsFlexible() bool

+ func (v *DescribeLogDirsResponse) ReadFrom(src []byte) error

+ func (v *DescribeLogDirsResponse) RequestKind() Request

+ func (v *DescribeLogDirsResponse) SetVersion(version int16)

+ func (v *DescribeLogDirsResponse) Throttle() (int32, bool)

+ type DescribeLogDirsResponseDir struct

+ Dir string

+ ErrorCode int16

+ Topics []DescribeLogDirsResponseDirTopic

+ UnknownTags Tags

+ func NewDescribeLogDirsResponseDir() DescribeLogDirsResponseDir

+ func (v *DescribeLogDirsResponseDir) Default()

+ type DescribeLogDirsResponseDirTopic struct

+ Partitions []DescribeLogDirsResponseDirTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewDescribeLogDirsResponseDirTopic() DescribeLogDirsResponseDirTopic

+ func (v *DescribeLogDirsResponseDirTopic) Default()

+ type DescribeLogDirsResponseDirTopicPartition struct

+ IsFuture bool

+ OffsetLag int64

+ Partition int32

+ Size int64

+ UnknownTags Tags

+ func NewDescribeLogDirsResponseDirTopicPartition() DescribeLogDirsResponseDirTopicPartition

+ func (v *DescribeLogDirsResponseDirTopicPartition) Default()

+ type DescribeProducersRequest struct

+ Topics []DescribeProducersRequestTopic

+ UnknownTags Tags

+ Version int16

+ func NewDescribeProducersRequest() DescribeProducersRequest

+ func NewPtrDescribeProducersRequest() *DescribeProducersRequest

+ func (*DescribeProducersRequest) Key() int16

+ func (*DescribeProducersRequest) MaxVersion() int16

+ func (v *DescribeProducersRequest) AppendTo(dst []byte) []byte

+ func (v *DescribeProducersRequest) Default()

+ func (v *DescribeProducersRequest) GetVersion() int16

+ func (v *DescribeProducersRequest) IsFlexible() bool

+ func (v *DescribeProducersRequest) ReadFrom(src []byte) error

+ func (v *DescribeProducersRequest) RequestWith(ctx context.Context, r Requestor) (*DescribeProducersResponse, error)

+ func (v *DescribeProducersRequest) ResponseKind() Response

+ func (v *DescribeProducersRequest) SetVersion(version int16)

+ type DescribeProducersRequestTopic struct

+ Partitions []int32

+ Topic string

+ UnknownTags Tags

+ func NewDescribeProducersRequestTopic() DescribeProducersRequestTopic

+ func (v *DescribeProducersRequestTopic) Default()

+ type DescribeProducersResponse struct

+ ThrottleMillis int32

+ Topics []DescribeProducersResponseTopic

+ UnknownTags Tags

+ Version int16

+ func NewDescribeProducersResponse() DescribeProducersResponse

+ func NewPtrDescribeProducersResponse() *DescribeProducersResponse

+ func (*DescribeProducersResponse) Key() int16

+ func (*DescribeProducersResponse) MaxVersion() int16

+ func (v *DescribeProducersResponse) AppendTo(dst []byte) []byte

+ func (v *DescribeProducersResponse) Default()

+ func (v *DescribeProducersResponse) GetVersion() int16

+ func (v *DescribeProducersResponse) IsFlexible() bool

+ func (v *DescribeProducersResponse) ReadFrom(src []byte) error

+ func (v *DescribeProducersResponse) RequestKind() Request

+ func (v *DescribeProducersResponse) SetVersion(version int16)

+ func (v *DescribeProducersResponse) Throttle() (int32, bool)

+ type DescribeProducersResponseTopic struct

+ Partitions []DescribeProducersResponseTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewDescribeProducersResponseTopic() DescribeProducersResponseTopic

+ func (v *DescribeProducersResponseTopic) Default()

+ type DescribeProducersResponseTopicPartition struct

+ ActiveProducers []DescribeProducersResponseTopicPartitionActiveProducer

+ ErrorCode int16

+ ErrorMessage *string

+ Partition int32

+ UnknownTags Tags

+ func NewDescribeProducersResponseTopicPartition() DescribeProducersResponseTopicPartition

+ func (v *DescribeProducersResponseTopicPartition) Default()

+ type DescribeProducersResponseTopicPartitionActiveProducer struct

+ CoordinatorEpoch int32

+ CurrentTxnStartOffset int64

+ LastSequence int32

+ LastTimestamp int64

+ ProducerEpoch int32

+ ProducerID int64

+ UnknownTags Tags

+ func NewDescribeProducersResponseTopicPartitionActiveProducer() DescribeProducersResponseTopicPartitionActiveProducer

+ func (v *DescribeProducersResponseTopicPartitionActiveProducer) Default()

+ type DescribeQuorumRequest struct

+ Topics []DescribeQuorumRequestTopic

+ UnknownTags Tags

+ Version int16

+ func NewDescribeQuorumRequest() DescribeQuorumRequest

+ func NewPtrDescribeQuorumRequest() *DescribeQuorumRequest

+ func (*DescribeQuorumRequest) Key() int16

+ func (*DescribeQuorumRequest) MaxVersion() int16

+ func (v *DescribeQuorumRequest) AppendTo(dst []byte) []byte

+ func (v *DescribeQuorumRequest) Default()

+ func (v *DescribeQuorumRequest) GetVersion() int16

+ func (v *DescribeQuorumRequest) IsAdminRequest()

+ func (v *DescribeQuorumRequest) IsFlexible() bool

+ func (v *DescribeQuorumRequest) ReadFrom(src []byte) error

+ func (v *DescribeQuorumRequest) RequestWith(ctx context.Context, r Requestor) (*DescribeQuorumResponse, error)

+ func (v *DescribeQuorumRequest) ResponseKind() Response

+ func (v *DescribeQuorumRequest) SetVersion(version int16)

+ type DescribeQuorumRequestTopic struct

+ Partitions []DescribeQuorumRequestTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewDescribeQuorumRequestTopic() DescribeQuorumRequestTopic

+ func (v *DescribeQuorumRequestTopic) Default()

+ type DescribeQuorumRequestTopicPartition struct

+ Partition int32

+ UnknownTags Tags

+ func NewDescribeQuorumRequestTopicPartition() DescribeQuorumRequestTopicPartition

+ func (v *DescribeQuorumRequestTopicPartition) Default()

+ type DescribeQuorumResponse struct

+ ErrorCode int16

+ Topics []DescribeQuorumResponseTopic

+ UnknownTags Tags

+ Version int16

+ func NewDescribeQuorumResponse() DescribeQuorumResponse

+ func NewPtrDescribeQuorumResponse() *DescribeQuorumResponse

+ func (*DescribeQuorumResponse) Key() int16

+ func (*DescribeQuorumResponse) MaxVersion() int16

+ func (v *DescribeQuorumResponse) AppendTo(dst []byte) []byte

+ func (v *DescribeQuorumResponse) Default()

+ func (v *DescribeQuorumResponse) GetVersion() int16

+ func (v *DescribeQuorumResponse) IsFlexible() bool

+ func (v *DescribeQuorumResponse) ReadFrom(src []byte) error

+ func (v *DescribeQuorumResponse) RequestKind() Request

+ func (v *DescribeQuorumResponse) SetVersion(version int16)

+ type DescribeQuorumResponseTopic struct

+ Partitions []DescribeQuorumResponseTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewDescribeQuorumResponseTopic() DescribeQuorumResponseTopic

+ func (v *DescribeQuorumResponseTopic) Default()

+ type DescribeQuorumResponseTopicPartition struct

+ CurrentVoters []DescribeQuorumResponseTopicPartitionReplicaState

+ ErrorCode int16

+ HighWatermark int64

+ LeaderEpoch int32

+ LeaderID int32

+ Observers []DescribeQuorumResponseTopicPartitionReplicaState

+ Partition int32

+ UnknownTags Tags

+ func NewDescribeQuorumResponseTopicPartition() DescribeQuorumResponseTopicPartition

+ func (v *DescribeQuorumResponseTopicPartition) Default()

+ type DescribeQuorumResponseTopicPartitionReplicaState struct

+ LogEndOffset int64

+ ReplicaID int32

+ UnknownTags Tags

+ func NewDescribeQuorumResponseTopicPartitionReplicaState() DescribeQuorumResponseTopicPartitionReplicaState

+ func (v *DescribeQuorumResponseTopicPartitionReplicaState) Default()

+ type DescribeTransactionsRequest struct

+ TransactionalIDs []string

+ UnknownTags Tags

+ Version int16

+ func NewDescribeTransactionsRequest() DescribeTransactionsRequest

+ func NewPtrDescribeTransactionsRequest() *DescribeTransactionsRequest

+ func (*DescribeTransactionsRequest) Key() int16

+ func (*DescribeTransactionsRequest) MaxVersion() int16

+ func (v *DescribeTransactionsRequest) AppendTo(dst []byte) []byte

+ func (v *DescribeTransactionsRequest) Default()

+ func (v *DescribeTransactionsRequest) GetVersion() int16

+ func (v *DescribeTransactionsRequest) IsFlexible() bool

+ func (v *DescribeTransactionsRequest) ReadFrom(src []byte) error

+ func (v *DescribeTransactionsRequest) RequestWith(ctx context.Context, r Requestor) (*DescribeTransactionsResponse, error)

+ func (v *DescribeTransactionsRequest) ResponseKind() Response

+ func (v *DescribeTransactionsRequest) SetVersion(version int16)

+ type DescribeTransactionsResponse struct

+ ThrottleMillis int32

+ TransactionStates []DescribeTransactionsResponseTransactionState

+ UnknownTags Tags

+ Version int16

+ func NewDescribeTransactionsResponse() DescribeTransactionsResponse

+ func NewPtrDescribeTransactionsResponse() *DescribeTransactionsResponse

+ func (*DescribeTransactionsResponse) Key() int16

+ func (*DescribeTransactionsResponse) MaxVersion() int16

+ func (v *DescribeTransactionsResponse) AppendTo(dst []byte) []byte

+ func (v *DescribeTransactionsResponse) Default()

+ func (v *DescribeTransactionsResponse) GetVersion() int16

+ func (v *DescribeTransactionsResponse) IsFlexible() bool

+ func (v *DescribeTransactionsResponse) ReadFrom(src []byte) error

+ func (v *DescribeTransactionsResponse) RequestKind() Request

+ func (v *DescribeTransactionsResponse) SetVersion(version int16)

+ func (v *DescribeTransactionsResponse) Throttle() (int32, bool)

+ type DescribeTransactionsResponseTransactionState struct

+ ErrorCode int16

+ ProducerEpoch int16

+ ProducerID int64

+ StartTimestamp int64

+ State string

+ TimeoutMillis int32

+ Topics []DescribeTransactionsResponseTransactionStateTopic

+ TransactionalID string

+ UnknownTags Tags

+ func NewDescribeTransactionsResponseTransactionState() DescribeTransactionsResponseTransactionState

+ func (v *DescribeTransactionsResponseTransactionState) Default()

+ type DescribeTransactionsResponseTransactionStateTopic struct

+ Partitions []int32

+ Topic string

+ UnknownTags Tags

+ func NewDescribeTransactionsResponseTransactionStateTopic() DescribeTransactionsResponseTransactionStateTopic

+ func (v *DescribeTransactionsResponseTransactionStateTopic) Default()

+ type DescribeUserSCRAMCredentialsRequest struct

+ UnknownTags Tags

+ Users []DescribeUserSCRAMCredentialsRequestUser

+ Version int16

+ func NewDescribeUserSCRAMCredentialsRequest() DescribeUserSCRAMCredentialsRequest

+ func NewPtrDescribeUserSCRAMCredentialsRequest() *DescribeUserSCRAMCredentialsRequest

+ func (*DescribeUserSCRAMCredentialsRequest) Key() int16

+ func (*DescribeUserSCRAMCredentialsRequest) MaxVersion() int16

+ func (v *DescribeUserSCRAMCredentialsRequest) AppendTo(dst []byte) []byte

+ func (v *DescribeUserSCRAMCredentialsRequest) Default()

+ func (v *DescribeUserSCRAMCredentialsRequest) GetVersion() int16

+ func (v *DescribeUserSCRAMCredentialsRequest) IsFlexible() bool

+ func (v *DescribeUserSCRAMCredentialsRequest) ReadFrom(src []byte) error

+ func (v *DescribeUserSCRAMCredentialsRequest) RequestWith(ctx context.Context, r Requestor) (*DescribeUserSCRAMCredentialsResponse, error)

+ func (v *DescribeUserSCRAMCredentialsRequest) ResponseKind() Response

+ func (v *DescribeUserSCRAMCredentialsRequest) SetVersion(version int16)

+ type DescribeUserSCRAMCredentialsRequestUser struct

+ Name string

+ UnknownTags Tags

+ func NewDescribeUserSCRAMCredentialsRequestUser() DescribeUserSCRAMCredentialsRequestUser

+ func (v *DescribeUserSCRAMCredentialsRequestUser) Default()

+ type DescribeUserSCRAMCredentialsResponse struct

+ ErrorCode int16

+ ErrorMessage *string

+ Results []DescribeUserSCRAMCredentialsResponseResult

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewDescribeUserSCRAMCredentialsResponse() DescribeUserSCRAMCredentialsResponse

+ func NewPtrDescribeUserSCRAMCredentialsResponse() *DescribeUserSCRAMCredentialsResponse

+ func (*DescribeUserSCRAMCredentialsResponse) Key() int16

+ func (*DescribeUserSCRAMCredentialsResponse) MaxVersion() int16

+ func (v *DescribeUserSCRAMCredentialsResponse) AppendTo(dst []byte) []byte

+ func (v *DescribeUserSCRAMCredentialsResponse) Default()

+ func (v *DescribeUserSCRAMCredentialsResponse) GetVersion() int16

+ func (v *DescribeUserSCRAMCredentialsResponse) IsFlexible() bool

+ func (v *DescribeUserSCRAMCredentialsResponse) ReadFrom(src []byte) error

+ func (v *DescribeUserSCRAMCredentialsResponse) RequestKind() Request

+ func (v *DescribeUserSCRAMCredentialsResponse) SetVersion(version int16)

+ func (v *DescribeUserSCRAMCredentialsResponse) Throttle() (int32, bool)

+ type DescribeUserSCRAMCredentialsResponseResult struct

+ CredentialInfos []DescribeUserSCRAMCredentialsResponseResultCredentialInfo

+ ErrorCode int16

+ ErrorMessage *string

+ UnknownTags Tags

+ User string

+ func NewDescribeUserSCRAMCredentialsResponseResult() DescribeUserSCRAMCredentialsResponseResult

+ func (v *DescribeUserSCRAMCredentialsResponseResult) Default()

+ type DescribeUserSCRAMCredentialsResponseResultCredentialInfo struct

+ Iterations int32

+ Mechanism int8

+ UnknownTags Tags

+ func NewDescribeUserSCRAMCredentialsResponseResultCredentialInfo() DescribeUserSCRAMCredentialsResponseResultCredentialInfo

+ func (v *DescribeUserSCRAMCredentialsResponseResultCredentialInfo) Default()

+ type ElectLeadersRequest struct

+ ElectionType int8

+ TimeoutMillis int32

+ Topics []ElectLeadersRequestTopic

+ UnknownTags Tags

+ Version int16

+ func NewElectLeadersRequest() ElectLeadersRequest

+ func NewPtrElectLeadersRequest() *ElectLeadersRequest

+ func (*ElectLeadersRequest) Key() int16

+ func (*ElectLeadersRequest) MaxVersion() int16

+ func (v *ElectLeadersRequest) AppendTo(dst []byte) []byte

+ func (v *ElectLeadersRequest) Default()

+ func (v *ElectLeadersRequest) GetVersion() int16

+ func (v *ElectLeadersRequest) IsAdminRequest()

+ func (v *ElectLeadersRequest) IsFlexible() bool

+ func (v *ElectLeadersRequest) ReadFrom(src []byte) error

+ func (v *ElectLeadersRequest) RequestWith(ctx context.Context, r Requestor) (*ElectLeadersResponse, error)

+ func (v *ElectLeadersRequest) ResponseKind() Response

+ func (v *ElectLeadersRequest) SetVersion(version int16)

+ func (v *ElectLeadersRequest) Timeout() int32

+ type ElectLeadersRequestTopic struct

+ Partitions []int32

+ Topic string

+ UnknownTags Tags

+ func NewElectLeadersRequestTopic() ElectLeadersRequestTopic

+ func (v *ElectLeadersRequestTopic) Default()

+ type ElectLeadersResponse struct

+ ErrorCode int16

+ ThrottleMillis int32

+ Topics []ElectLeadersResponseTopic

+ UnknownTags Tags

+ Version int16

+ func NewElectLeadersResponse() ElectLeadersResponse

+ func NewPtrElectLeadersResponse() *ElectLeadersResponse

+ func (*ElectLeadersResponse) Key() int16

+ func (*ElectLeadersResponse) MaxVersion() int16

+ func (v *ElectLeadersResponse) AppendTo(dst []byte) []byte

+ func (v *ElectLeadersResponse) Default()

+ func (v *ElectLeadersResponse) GetVersion() int16

+ func (v *ElectLeadersResponse) IsFlexible() bool

+ func (v *ElectLeadersResponse) ReadFrom(src []byte) error

+ func (v *ElectLeadersResponse) RequestKind() Request

+ func (v *ElectLeadersResponse) SetVersion(version int16)

+ func (v *ElectLeadersResponse) Throttle() (int32, bool)

+ type ElectLeadersResponseTopic struct

+ Partitions []ElectLeadersResponseTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewElectLeadersResponseTopic() ElectLeadersResponseTopic

+ func (v *ElectLeadersResponseTopic) Default()

+ type ElectLeadersResponseTopicPartition struct

+ ErrorCode int16

+ ErrorMessage *string

+ Partition int32

+ UnknownTags Tags

+ func NewElectLeadersResponseTopicPartition() ElectLeadersResponseTopicPartition

+ func (v *ElectLeadersResponseTopicPartition) Default()

+ type EndQuorumEpochRequest struct

+ ClusterID *string

+ Topics []EndQuorumEpochRequestTopic

+ Version int16

+ func NewEndQuorumEpochRequest() EndQuorumEpochRequest

+ func NewPtrEndQuorumEpochRequest() *EndQuorumEpochRequest

+ func (*EndQuorumEpochRequest) Key() int16

+ func (*EndQuorumEpochRequest) MaxVersion() int16

+ func (v *EndQuorumEpochRequest) AppendTo(dst []byte) []byte

+ func (v *EndQuorumEpochRequest) Default()

+ func (v *EndQuorumEpochRequest) GetVersion() int16

+ func (v *EndQuorumEpochRequest) IsAdminRequest()

+ func (v *EndQuorumEpochRequest) IsFlexible() bool

+ func (v *EndQuorumEpochRequest) ReadFrom(src []byte) error

+ func (v *EndQuorumEpochRequest) RequestWith(ctx context.Context, r Requestor) (*EndQuorumEpochResponse, error)

+ func (v *EndQuorumEpochRequest) ResponseKind() Response

+ func (v *EndQuorumEpochRequest) SetVersion(version int16)

+ type EndQuorumEpochRequestTopic struct

+ Partitions []EndQuorumEpochRequestTopicPartition

+ Topic string

+ func NewEndQuorumEpochRequestTopic() EndQuorumEpochRequestTopic

+ func (v *EndQuorumEpochRequestTopic) Default()

+ type EndQuorumEpochRequestTopicPartition struct

+ LeaderEpoch int32

+ LeaderID int32

+ Partition int32

+ PreferredSuccessors []int32

+ func NewEndQuorumEpochRequestTopicPartition() EndQuorumEpochRequestTopicPartition

+ func (v *EndQuorumEpochRequestTopicPartition) Default()

+ type EndQuorumEpochResponse struct

+ ErrorCode int16

+ Topics []EndQuorumEpochResponseTopic

+ Version int16

+ func NewEndQuorumEpochResponse() EndQuorumEpochResponse

+ func NewPtrEndQuorumEpochResponse() *EndQuorumEpochResponse

+ func (*EndQuorumEpochResponse) Key() int16

+ func (*EndQuorumEpochResponse) MaxVersion() int16

+ func (v *EndQuorumEpochResponse) AppendTo(dst []byte) []byte

+ func (v *EndQuorumEpochResponse) Default()

+ func (v *EndQuorumEpochResponse) GetVersion() int16

+ func (v *EndQuorumEpochResponse) IsFlexible() bool

+ func (v *EndQuorumEpochResponse) ReadFrom(src []byte) error

+ func (v *EndQuorumEpochResponse) RequestKind() Request

+ func (v *EndQuorumEpochResponse) SetVersion(version int16)

+ type EndQuorumEpochResponseTopic struct

+ Partitions []EndQuorumEpochResponseTopicPartition

+ Topic string

+ func NewEndQuorumEpochResponseTopic() EndQuorumEpochResponseTopic

+ func (v *EndQuorumEpochResponseTopic) Default()

+ type EndQuorumEpochResponseTopicPartition struct

+ ErrorCode int16

+ LeaderEpoch int32

+ LeaderID int32

+ Partition int32

+ func NewEndQuorumEpochResponseTopicPartition() EndQuorumEpochResponseTopicPartition

+ func (v *EndQuorumEpochResponseTopicPartition) Default()

+ type EndTxnMarker struct

+ CoordinatorEpoch int32

+ Version int16

+ func NewEndTxnMarker() EndTxnMarker

+ func (v *EndTxnMarker) AppendTo(dst []byte) []byte

+ func (v *EndTxnMarker) Default()

+ func (v *EndTxnMarker) ReadFrom(src []byte) error

+ type EndTxnRequest struct

+ Commit bool

+ ProducerEpoch int16

+ ProducerID int64

+ TransactionalID string

+ UnknownTags Tags

+ Version int16

+ func NewEndTxnRequest() EndTxnRequest

+ func NewPtrEndTxnRequest() *EndTxnRequest

+ func (*EndTxnRequest) Key() int16

+ func (*EndTxnRequest) MaxVersion() int16

+ func (v *EndTxnRequest) AppendTo(dst []byte) []byte

+ func (v *EndTxnRequest) Default()

+ func (v *EndTxnRequest) GetVersion() int16

+ func (v *EndTxnRequest) IsFlexible() bool

+ func (v *EndTxnRequest) IsTxnCoordinatorRequest()

+ func (v *EndTxnRequest) ReadFrom(src []byte) error

+ func (v *EndTxnRequest) RequestWith(ctx context.Context, r Requestor) (*EndTxnResponse, error)

+ func (v *EndTxnRequest) ResponseKind() Response

+ func (v *EndTxnRequest) SetVersion(version int16)

+ type EndTxnResponse struct

+ ErrorCode int16

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewEndTxnResponse() EndTxnResponse

+ func NewPtrEndTxnResponse() *EndTxnResponse

+ func (*EndTxnResponse) Key() int16

+ func (*EndTxnResponse) MaxVersion() int16

+ func (v *EndTxnResponse) AppendTo(dst []byte) []byte

+ func (v *EndTxnResponse) Default()

+ func (v *EndTxnResponse) GetVersion() int16

+ func (v *EndTxnResponse) IsFlexible() bool

+ func (v *EndTxnResponse) ReadFrom(src []byte) error

+ func (v *EndTxnResponse) RequestKind() Request

+ func (v *EndTxnResponse) SetVersion(version int16)

+ func (v *EndTxnResponse) Throttle() (int32, bool)

+ type EnvelopeRequest struct

+ ClientHostAddress []byte

+ RequestData []byte

+ RequestPrincipal []byte

+ UnknownTags Tags

+ Version int16

+ func NewEnvelopeRequest() EnvelopeRequest

+ func NewPtrEnvelopeRequest() *EnvelopeRequest

+ func (*EnvelopeRequest) Key() int16

+ func (*EnvelopeRequest) MaxVersion() int16

+ func (v *EnvelopeRequest) AppendTo(dst []byte) []byte

+ func (v *EnvelopeRequest) Default()

+ func (v *EnvelopeRequest) GetVersion() int16

+ func (v *EnvelopeRequest) IsAdminRequest()

+ func (v *EnvelopeRequest) IsFlexible() bool

+ func (v *EnvelopeRequest) ReadFrom(src []byte) error

+ func (v *EnvelopeRequest) RequestWith(ctx context.Context, r Requestor) (*EnvelopeResponse, error)

+ func (v *EnvelopeRequest) ResponseKind() Response

+ func (v *EnvelopeRequest) SetVersion(version int16)

+ type EnvelopeResponse struct

+ ErrorCode int16

+ ResponseData []byte

+ UnknownTags Tags

+ Version int16

+ func NewEnvelopeResponse() EnvelopeResponse

+ func NewPtrEnvelopeResponse() *EnvelopeResponse

+ func (*EnvelopeResponse) Key() int16

+ func (*EnvelopeResponse) MaxVersion() int16

+ func (v *EnvelopeResponse) AppendTo(dst []byte) []byte

+ func (v *EnvelopeResponse) Default()

+ func (v *EnvelopeResponse) GetVersion() int16

+ func (v *EnvelopeResponse) IsFlexible() bool

+ func (v *EnvelopeResponse) ReadFrom(src []byte) error

+ func (v *EnvelopeResponse) RequestKind() Request

+ func (v *EnvelopeResponse) SetVersion(version int16)

+ type ExpireDelegationTokenRequest struct

+ ExpiryPeriodMillis int64

+ HMAC []byte

+ UnknownTags Tags

+ Version int16

+ func NewExpireDelegationTokenRequest() ExpireDelegationTokenRequest

+ func NewPtrExpireDelegationTokenRequest() *ExpireDelegationTokenRequest

+ func (*ExpireDelegationTokenRequest) Key() int16

+ func (*ExpireDelegationTokenRequest) MaxVersion() int16

+ func (v *ExpireDelegationTokenRequest) AppendTo(dst []byte) []byte

+ func (v *ExpireDelegationTokenRequest) Default()

+ func (v *ExpireDelegationTokenRequest) GetVersion() int16

+ func (v *ExpireDelegationTokenRequest) IsFlexible() bool

+ func (v *ExpireDelegationTokenRequest) ReadFrom(src []byte) error

+ func (v *ExpireDelegationTokenRequest) RequestWith(ctx context.Context, r Requestor) (*ExpireDelegationTokenResponse, error)

+ func (v *ExpireDelegationTokenRequest) ResponseKind() Response

+ func (v *ExpireDelegationTokenRequest) SetVersion(version int16)

+ type ExpireDelegationTokenResponse struct

+ ErrorCode int16

+ ExpiryTimestamp int64

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewExpireDelegationTokenResponse() ExpireDelegationTokenResponse

+ func NewPtrExpireDelegationTokenResponse() *ExpireDelegationTokenResponse

+ func (*ExpireDelegationTokenResponse) Key() int16

+ func (*ExpireDelegationTokenResponse) MaxVersion() int16

+ func (v *ExpireDelegationTokenResponse) AppendTo(dst []byte) []byte

+ func (v *ExpireDelegationTokenResponse) Default()

+ func (v *ExpireDelegationTokenResponse) GetVersion() int16

+ func (v *ExpireDelegationTokenResponse) IsFlexible() bool

+ func (v *ExpireDelegationTokenResponse) ReadFrom(src []byte) error

+ func (v *ExpireDelegationTokenResponse) RequestKind() Request

+ func (v *ExpireDelegationTokenResponse) SetVersion(version int16)

+ func (v *ExpireDelegationTokenResponse) Throttle() (int32, bool)

+ type FetchRequest struct

+ ClusterID *string

+ ForgottenTopics []FetchRequestForgottenTopic

+ IsolationLevel int8

+ MaxBytes int32

+ MaxWaitMillis int32

+ MinBytes int32

+ Rack string

+ ReplicaID int32

+ SessionEpoch int32

+ SessionID int32

+ Topics []FetchRequestTopic

+ UnknownTags Tags

+ Version int16

+ func NewFetchRequest() FetchRequest

+ func NewPtrFetchRequest() *FetchRequest

+ func (*FetchRequest) Key() int16

+ func (*FetchRequest) MaxVersion() int16

+ func (v *FetchRequest) AppendTo(dst []byte) []byte

+ func (v *FetchRequest) Default()

+ func (v *FetchRequest) GetVersion() int16

+ func (v *FetchRequest) IsFlexible() bool

+ func (v *FetchRequest) ReadFrom(src []byte) error

+ func (v *FetchRequest) RequestWith(ctx context.Context, r Requestor) (*FetchResponse, error)

+ func (v *FetchRequest) ResponseKind() Response

+ func (v *FetchRequest) SetVersion(version int16)

+ type FetchRequestForgottenTopic struct

+ Partitions []int32

+ Topic string

+ TopicID [16]byte

+ UnknownTags Tags

+ func NewFetchRequestForgottenTopic() FetchRequestForgottenTopic

+ func (v *FetchRequestForgottenTopic) Default()

+ type FetchRequestTopic struct

+ Partitions []FetchRequestTopicPartition

+ Topic string

+ TopicID [16]byte

+ UnknownTags Tags

+ func NewFetchRequestTopic() FetchRequestTopic

+ func (v *FetchRequestTopic) Default()

+ type FetchRequestTopicPartition struct

+ CurrentLeaderEpoch int32

+ FetchOffset int64

+ LastFetchedEpoch int32

+ LogStartOffset int64

+ Partition int32

+ PartitionMaxBytes int32

+ UnknownTags Tags

+ func NewFetchRequestTopicPartition() FetchRequestTopicPartition

+ func (v *FetchRequestTopicPartition) Default()

+ type FetchResponse struct

+ ErrorCode int16

+ SessionID int32

+ ThrottleMillis int32

+ Topics []FetchResponseTopic

+ UnknownTags Tags

+ Version int16

+ func NewFetchResponse() FetchResponse

+ func NewPtrFetchResponse() *FetchResponse

+ func (*FetchResponse) Key() int16

+ func (*FetchResponse) MaxVersion() int16

+ func (v *FetchResponse) AppendTo(dst []byte) []byte

+ func (v *FetchResponse) Default()

+ func (v *FetchResponse) GetVersion() int16

+ func (v *FetchResponse) IsFlexible() bool

+ func (v *FetchResponse) ReadFrom(src []byte) error

+ func (v *FetchResponse) RequestKind() Request

+ func (v *FetchResponse) SetVersion(version int16)

+ func (v *FetchResponse) Throttle() (int32, bool)

+ type FetchResponseTopic struct

+ Partitions []FetchResponseTopicPartition

+ Topic string

+ TopicID [16]byte

+ UnknownTags Tags

+ func NewFetchResponseTopic() FetchResponseTopic

+ func (v *FetchResponseTopic) Default()

+ type FetchResponseTopicPartition struct

+ AbortedTransactions []FetchResponseTopicPartitionAbortedTransaction

+ CurrentLeader FetchResponseTopicPartitionCurrentLeader

+ DivergingEpoch FetchResponseTopicPartitionDivergingEpoch

+ ErrorCode int16

+ HighWatermark int64

+ LastStableOffset int64

+ LogStartOffset int64

+ Partition int32

+ PreferredReadReplica int32

+ RecordBatches []byte

+ SnapshotID FetchResponseTopicPartitionSnapshotID

+ UnknownTags Tags

+ func NewFetchResponseTopicPartition() FetchResponseTopicPartition

+ func (v *FetchResponseTopicPartition) Default()

+ type FetchResponseTopicPartitionAbortedTransaction struct

+ FirstOffset int64

+ ProducerID int64

+ UnknownTags Tags

+ func NewFetchResponseTopicPartitionAbortedTransaction() FetchResponseTopicPartitionAbortedTransaction

+ func (v *FetchResponseTopicPartitionAbortedTransaction) Default()

+ type FetchResponseTopicPartitionCurrentLeader struct

+ LeaderEpoch int32

+ LeaderID int32

+ UnknownTags Tags

+ func NewFetchResponseTopicPartitionCurrentLeader() FetchResponseTopicPartitionCurrentLeader

+ func (v *FetchResponseTopicPartitionCurrentLeader) Default()

+ type FetchResponseTopicPartitionDivergingEpoch struct

+ EndOffset int64

+ Epoch int32

+ UnknownTags Tags

+ func NewFetchResponseTopicPartitionDivergingEpoch() FetchResponseTopicPartitionDivergingEpoch

+ func (v *FetchResponseTopicPartitionDivergingEpoch) Default()

+ type FetchResponseTopicPartitionSnapshotID struct

+ EndOffset int64

+ Epoch int32

+ UnknownTags Tags

+ func NewFetchResponseTopicPartitionSnapshotID() FetchResponseTopicPartitionSnapshotID

+ func (v *FetchResponseTopicPartitionSnapshotID) Default()

+ type FetchSnapshotRequest struct

+ ClusterID *string

+ MaxBytes int32

+ ReplicaID int32

+ Topics []FetchSnapshotRequestTopic

+ UnknownTags Tags

+ Version int16

+ func NewFetchSnapshotRequest() FetchSnapshotRequest

+ func NewPtrFetchSnapshotRequest() *FetchSnapshotRequest

+ func (*FetchSnapshotRequest) Key() int16

+ func (*FetchSnapshotRequest) MaxVersion() int16

+ func (v *FetchSnapshotRequest) AppendTo(dst []byte) []byte

+ func (v *FetchSnapshotRequest) Default()

+ func (v *FetchSnapshotRequest) GetVersion() int16

+ func (v *FetchSnapshotRequest) IsFlexible() bool

+ func (v *FetchSnapshotRequest) ReadFrom(src []byte) error

+ func (v *FetchSnapshotRequest) RequestWith(ctx context.Context, r Requestor) (*FetchSnapshotResponse, error)

+ func (v *FetchSnapshotRequest) ResponseKind() Response

+ func (v *FetchSnapshotRequest) SetVersion(version int16)

+ type FetchSnapshotRequestTopic struct

+ Partitions []FetchSnapshotRequestTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewFetchSnapshotRequestTopic() FetchSnapshotRequestTopic

+ func (v *FetchSnapshotRequestTopic) Default()

+ type FetchSnapshotRequestTopicPartition struct

+ CurrentLeaderEpoch int32

+ Partition int32

+ Position int64

+ SnapshotID FetchSnapshotRequestTopicPartitionSnapshotID

+ UnknownTags Tags

+ func NewFetchSnapshotRequestTopicPartition() FetchSnapshotRequestTopicPartition

+ func (v *FetchSnapshotRequestTopicPartition) Default()

+ type FetchSnapshotRequestTopicPartitionSnapshotID struct

+ EndOffset int64

+ Epoch int32

+ UnknownTags Tags

+ func NewFetchSnapshotRequestTopicPartitionSnapshotID() FetchSnapshotRequestTopicPartitionSnapshotID

+ func (v *FetchSnapshotRequestTopicPartitionSnapshotID) Default()

+ type FetchSnapshotResponse struct

+ ErrorCode int16

+ ThrottleMillis int32

+ Topics []FetchSnapshotResponseTopic

+ UnknownTags Tags

+ Version int16

+ func NewFetchSnapshotResponse() FetchSnapshotResponse

+ func NewPtrFetchSnapshotResponse() *FetchSnapshotResponse

+ func (*FetchSnapshotResponse) Key() int16

+ func (*FetchSnapshotResponse) MaxVersion() int16

+ func (v *FetchSnapshotResponse) AppendTo(dst []byte) []byte

+ func (v *FetchSnapshotResponse) Default()

+ func (v *FetchSnapshotResponse) GetVersion() int16

+ func (v *FetchSnapshotResponse) IsFlexible() bool

+ func (v *FetchSnapshotResponse) ReadFrom(src []byte) error

+ func (v *FetchSnapshotResponse) RequestKind() Request

+ func (v *FetchSnapshotResponse) SetVersion(version int16)

+ func (v *FetchSnapshotResponse) Throttle() (int32, bool)

+ type FetchSnapshotResponseTopic struct

+ Partitions []FetchSnapshotResponseTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewFetchSnapshotResponseTopic() FetchSnapshotResponseTopic

+ func (v *FetchSnapshotResponseTopic) Default()

+ type FetchSnapshotResponseTopicPartition struct

+ Bytes []byte

+ CurrentLeader FetchSnapshotResponseTopicPartitionCurrentLeader

+ ErrorCode int16

+ Partition int32

+ Position int64

+ Size int64

+ SnapshotID FetchSnapshotResponseTopicPartitionSnapshotID

+ UnknownTags Tags

+ func NewFetchSnapshotResponseTopicPartition() FetchSnapshotResponseTopicPartition

+ func (v *FetchSnapshotResponseTopicPartition) Default()

+ type FetchSnapshotResponseTopicPartitionCurrentLeader struct

+ LeaderEpoch int32

+ LeaderID int32

+ UnknownTags Tags

+ func NewFetchSnapshotResponseTopicPartitionCurrentLeader() FetchSnapshotResponseTopicPartitionCurrentLeader

+ func (v *FetchSnapshotResponseTopicPartitionCurrentLeader) Default()

+ type FetchSnapshotResponseTopicPartitionSnapshotID struct

+ EndOffset int64

+ Epoch int32

+ UnknownTags Tags

+ func NewFetchSnapshotResponseTopicPartitionSnapshotID() FetchSnapshotResponseTopicPartitionSnapshotID

+ func (v *FetchSnapshotResponseTopicPartitionSnapshotID) Default()

+ type FindCoordinatorRequest struct

+ CoordinatorKey string

+ CoordinatorKeys []string

+ CoordinatorType int8

+ UnknownTags Tags

+ Version int16

+ func NewFindCoordinatorRequest() FindCoordinatorRequest

+ func NewPtrFindCoordinatorRequest() *FindCoordinatorRequest

+ func (*FindCoordinatorRequest) Key() int16

+ func (*FindCoordinatorRequest) MaxVersion() int16

+ func (v *FindCoordinatorRequest) AppendTo(dst []byte) []byte

+ func (v *FindCoordinatorRequest) Default()

+ func (v *FindCoordinatorRequest) GetVersion() int16

+ func (v *FindCoordinatorRequest) IsFlexible() bool

+ func (v *FindCoordinatorRequest) ReadFrom(src []byte) error

+ func (v *FindCoordinatorRequest) RequestWith(ctx context.Context, r Requestor) (*FindCoordinatorResponse, error)

+ func (v *FindCoordinatorRequest) ResponseKind() Response

+ func (v *FindCoordinatorRequest) SetVersion(version int16)

+ type FindCoordinatorResponse struct

+ Coordinators []FindCoordinatorResponseCoordinator

+ ErrorCode int16

+ ErrorMessage *string

+ Host string

+ NodeID int32

+ Port int32

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewFindCoordinatorResponse() FindCoordinatorResponse

+ func NewPtrFindCoordinatorResponse() *FindCoordinatorResponse

+ func (*FindCoordinatorResponse) Key() int16

+ func (*FindCoordinatorResponse) MaxVersion() int16

+ func (v *FindCoordinatorResponse) AppendTo(dst []byte) []byte

+ func (v *FindCoordinatorResponse) Default()

+ func (v *FindCoordinatorResponse) GetVersion() int16

+ func (v *FindCoordinatorResponse) IsFlexible() bool

+ func (v *FindCoordinatorResponse) ReadFrom(src []byte) error

+ func (v *FindCoordinatorResponse) RequestKind() Request

+ func (v *FindCoordinatorResponse) SetVersion(version int16)

+ func (v *FindCoordinatorResponse) Throttle() (int32, bool)

+ type FindCoordinatorResponseCoordinator struct

+ ErrorCode int16

+ ErrorMessage *string

+ Host string

+ Key string

+ NodeID int32

+ Port int32

+ UnknownTags Tags

+ func NewFindCoordinatorResponseCoordinator() FindCoordinatorResponseCoordinator

+ func (v *FindCoordinatorResponseCoordinator) Default()

+ type GroupCoordinatorRequest interface

+ IsGroupCoordinatorRequest func()

+ type GroupMemberAssignment = ConsumerMemberAssignment

+ type GroupMemberMetadata = ConsumerMemberMetadata

+ type GroupMetadataKey struct

+ Group string

+ Version int16

+ func NewGroupMetadataKey() GroupMetadataKey

+ func (v *GroupMetadataKey) AppendTo(dst []byte) []byte

+ func (v *GroupMetadataKey) Default()

+ func (v *GroupMetadataKey) ReadFrom(src []byte) error

+ type GroupMetadataValue struct

+ CurrentStateTimestamp int64

+ Generation int32

+ Leader *string

+ Members []GroupMetadataValueMember

+ Protocol *string

+ ProtocolType string

+ Version int16

+ func NewGroupMetadataValue() GroupMetadataValue

+ func (v *GroupMetadataValue) AppendTo(dst []byte) []byte

+ func (v *GroupMetadataValue) Default()

+ func (v *GroupMetadataValue) ReadFrom(src []byte) error

+ type GroupMetadataValueMember struct

+ Assignment []byte

+ ClientHost string

+ ClientID string

+ InstanceID *string

+ MemberID string

+ RebalanceTimeoutMillis int32

+ SessionTimeoutMillis int32

+ Subscription []byte

+ func NewGroupMetadataValueMember() GroupMetadataValueMember

+ func (v *GroupMetadataValueMember) Default()

+ type Header struct

+ Key string

+ Value []byte

+ func NewHeader() Header

+ func (v *Header) AppendTo(dst []byte) []byte

+ func (v *Header) Default()

+ func (v *Header) ReadFrom(src []byte) error

+ type HeartbeatRequest struct

+ Generation int32

+ Group string

+ InstanceID *string

+ MemberID string

+ UnknownTags Tags

+ Version int16

+ func NewHeartbeatRequest() HeartbeatRequest

+ func NewPtrHeartbeatRequest() *HeartbeatRequest

+ func (*HeartbeatRequest) Key() int16

+ func (*HeartbeatRequest) MaxVersion() int16

+ func (v *HeartbeatRequest) AppendTo(dst []byte) []byte

+ func (v *HeartbeatRequest) Default()

+ func (v *HeartbeatRequest) GetVersion() int16

+ func (v *HeartbeatRequest) IsFlexible() bool

+ func (v *HeartbeatRequest) IsGroupCoordinatorRequest()

+ func (v *HeartbeatRequest) ReadFrom(src []byte) error

+ func (v *HeartbeatRequest) RequestWith(ctx context.Context, r Requestor) (*HeartbeatResponse, error)

+ func (v *HeartbeatRequest) ResponseKind() Response

+ func (v *HeartbeatRequest) SetVersion(version int16)

+ type HeartbeatResponse struct

+ ErrorCode int16

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewHeartbeatResponse() HeartbeatResponse

+ func NewPtrHeartbeatResponse() *HeartbeatResponse

+ func (*HeartbeatResponse) Key() int16

+ func (*HeartbeatResponse) MaxVersion() int16

+ func (v *HeartbeatResponse) AppendTo(dst []byte) []byte

+ func (v *HeartbeatResponse) Default()

+ func (v *HeartbeatResponse) GetVersion() int16

+ func (v *HeartbeatResponse) IsFlexible() bool

+ func (v *HeartbeatResponse) ReadFrom(src []byte) error

+ func (v *HeartbeatResponse) RequestKind() Request

+ func (v *HeartbeatResponse) SetVersion(version int16)

+ func (v *HeartbeatResponse) Throttle() (int32, bool)

+ type IncrementalAlterConfigOp int8

+ const IncrementalAlterConfigOpAppend

+ const IncrementalAlterConfigOpDelete

+ const IncrementalAlterConfigOpSet

+ const IncrementalAlterConfigOpSubtract

+ func ParseIncrementalAlterConfigOp(s string) (IncrementalAlterConfigOp, error)

+ func (e *IncrementalAlterConfigOp) UnmarshalText(text []byte) error

+ func (e IncrementalAlterConfigOp) MarshalText() (text []byte, err error)

+ func (v IncrementalAlterConfigOp) String() string

+ type IncrementalAlterConfigsRequest struct

+ Resources []IncrementalAlterConfigsRequestResource

+ UnknownTags Tags

+ ValidateOnly bool

+ Version int16

+ func NewIncrementalAlterConfigsRequest() IncrementalAlterConfigsRequest

+ func NewPtrIncrementalAlterConfigsRequest() *IncrementalAlterConfigsRequest

+ func (*IncrementalAlterConfigsRequest) Key() int16

+ func (*IncrementalAlterConfigsRequest) MaxVersion() int16

+ func (v *IncrementalAlterConfigsRequest) AppendTo(dst []byte) []byte

+ func (v *IncrementalAlterConfigsRequest) Default()

+ func (v *IncrementalAlterConfigsRequest) GetVersion() int16

+ func (v *IncrementalAlterConfigsRequest) IsFlexible() bool

+ func (v *IncrementalAlterConfigsRequest) ReadFrom(src []byte) error

+ func (v *IncrementalAlterConfigsRequest) RequestWith(ctx context.Context, r Requestor) (*IncrementalAlterConfigsResponse, error)

+ func (v *IncrementalAlterConfigsRequest) ResponseKind() Response

+ func (v *IncrementalAlterConfigsRequest) SetVersion(version int16)

+ type IncrementalAlterConfigsRequestResource struct

+ Configs []IncrementalAlterConfigsRequestResourceConfig

+ ResourceName string

+ ResourceType ConfigResourceType

+ UnknownTags Tags

+ func NewIncrementalAlterConfigsRequestResource() IncrementalAlterConfigsRequestResource

+ func (v *IncrementalAlterConfigsRequestResource) Default()

+ type IncrementalAlterConfigsRequestResourceConfig struct

+ Name string

+ Op IncrementalAlterConfigOp

+ UnknownTags Tags

+ Value *string

+ func NewIncrementalAlterConfigsRequestResourceConfig() IncrementalAlterConfigsRequestResourceConfig

+ func (v *IncrementalAlterConfigsRequestResourceConfig) Default()

+ type IncrementalAlterConfigsResponse struct

+ Resources []IncrementalAlterConfigsResponseResource

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewIncrementalAlterConfigsResponse() IncrementalAlterConfigsResponse

+ func NewPtrIncrementalAlterConfigsResponse() *IncrementalAlterConfigsResponse

+ func (*IncrementalAlterConfigsResponse) Key() int16

+ func (*IncrementalAlterConfigsResponse) MaxVersion() int16

+ func (v *IncrementalAlterConfigsResponse) AppendTo(dst []byte) []byte

+ func (v *IncrementalAlterConfigsResponse) Default()

+ func (v *IncrementalAlterConfigsResponse) GetVersion() int16

+ func (v *IncrementalAlterConfigsResponse) IsFlexible() bool

+ func (v *IncrementalAlterConfigsResponse) ReadFrom(src []byte) error

+ func (v *IncrementalAlterConfigsResponse) RequestKind() Request

+ func (v *IncrementalAlterConfigsResponse) SetVersion(version int16)

+ func (v *IncrementalAlterConfigsResponse) Throttle() (int32, bool)

+ type IncrementalAlterConfigsResponseResource struct

+ ErrorCode int16

+ ErrorMessage *string

+ ResourceName string

+ ResourceType ConfigResourceType

+ UnknownTags Tags

+ func NewIncrementalAlterConfigsResponseResource() IncrementalAlterConfigsResponseResource

+ func (v *IncrementalAlterConfigsResponseResource) Default()

+ type InitProducerIDRequest struct

+ ProducerEpoch int16

+ ProducerID int64

+ TransactionTimeoutMillis int32

+ TransactionalID *string

+ UnknownTags Tags

+ Version int16

+ func NewInitProducerIDRequest() InitProducerIDRequest

+ func NewPtrInitProducerIDRequest() *InitProducerIDRequest

+ func (*InitProducerIDRequest) Key() int16

+ func (*InitProducerIDRequest) MaxVersion() int16

+ func (v *InitProducerIDRequest) AppendTo(dst []byte) []byte

+ func (v *InitProducerIDRequest) Default()

+ func (v *InitProducerIDRequest) GetVersion() int16

+ func (v *InitProducerIDRequest) IsFlexible() bool

+ func (v *InitProducerIDRequest) IsTxnCoordinatorRequest()

+ func (v *InitProducerIDRequest) ReadFrom(src []byte) error

+ func (v *InitProducerIDRequest) RequestWith(ctx context.Context, r Requestor) (*InitProducerIDResponse, error)

+ func (v *InitProducerIDRequest) ResponseKind() Response

+ func (v *InitProducerIDRequest) SetVersion(version int16)

+ type InitProducerIDResponse struct

+ ErrorCode int16

+ ProducerEpoch int16

+ ProducerID int64

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewInitProducerIDResponse() InitProducerIDResponse

+ func NewPtrInitProducerIDResponse() *InitProducerIDResponse

+ func (*InitProducerIDResponse) Key() int16

+ func (*InitProducerIDResponse) MaxVersion() int16

+ func (v *InitProducerIDResponse) AppendTo(dst []byte) []byte

+ func (v *InitProducerIDResponse) Default()

+ func (v *InitProducerIDResponse) GetVersion() int16

+ func (v *InitProducerIDResponse) IsFlexible() bool

+ func (v *InitProducerIDResponse) ReadFrom(src []byte) error

+ func (v *InitProducerIDResponse) RequestKind() Request

+ func (v *InitProducerIDResponse) SetVersion(version int16)

+ func (v *InitProducerIDResponse) Throttle() (int32, bool)

+ type JoinGroupRequest struct

+ Group string

+ InstanceID *string

+ MemberID string

+ ProtocolType string

+ Protocols []JoinGroupRequestProtocol

+ Reason *string

+ RebalanceTimeoutMillis int32

+ SessionTimeoutMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewJoinGroupRequest() JoinGroupRequest

+ func NewPtrJoinGroupRequest() *JoinGroupRequest

+ func (*JoinGroupRequest) Key() int16

+ func (*JoinGroupRequest) MaxVersion() int16

+ func (v *JoinGroupRequest) AppendTo(dst []byte) []byte

+ func (v *JoinGroupRequest) Default()

+ func (v *JoinGroupRequest) GetVersion() int16

+ func (v *JoinGroupRequest) IsFlexible() bool

+ func (v *JoinGroupRequest) IsGroupCoordinatorRequest()

+ func (v *JoinGroupRequest) ReadFrom(src []byte) error

+ func (v *JoinGroupRequest) RequestWith(ctx context.Context, r Requestor) (*JoinGroupResponse, error)

+ func (v *JoinGroupRequest) ResponseKind() Response

+ func (v *JoinGroupRequest) SetVersion(version int16)

+ type JoinGroupRequestProtocol struct

+ Metadata []byte

+ Name string

+ UnknownTags Tags

+ func NewJoinGroupRequestProtocol() JoinGroupRequestProtocol

+ func (v *JoinGroupRequestProtocol) Default()

+ type JoinGroupResponse struct

+ ErrorCode int16

+ Generation int32

+ LeaderID string

+ MemberID string

+ Members []JoinGroupResponseMember

+ Protocol *string

+ ProtocolType *string

+ SkipAssignment bool

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewJoinGroupResponse() JoinGroupResponse

+ func NewPtrJoinGroupResponse() *JoinGroupResponse

+ func (*JoinGroupResponse) Key() int16

+ func (*JoinGroupResponse) MaxVersion() int16

+ func (v *JoinGroupResponse) AppendTo(dst []byte) []byte

+ func (v *JoinGroupResponse) Default()

+ func (v *JoinGroupResponse) GetVersion() int16

+ func (v *JoinGroupResponse) IsFlexible() bool

+ func (v *JoinGroupResponse) ReadFrom(src []byte) error

+ func (v *JoinGroupResponse) RequestKind() Request

+ func (v *JoinGroupResponse) SetVersion(version int16)

+ func (v *JoinGroupResponse) Throttle() (int32, bool)

+ type JoinGroupResponseMember struct

+ InstanceID *string

+ MemberID string

+ ProtocolMetadata []byte

+ UnknownTags Tags

+ func NewJoinGroupResponseMember() JoinGroupResponseMember

+ func (v *JoinGroupResponseMember) Default()

+ type Key int16

+ const AddOffsetsToTxn

+ const AddPartitionsToTxn

+ const AllocateProducerIDs

+ const AlterClientQuotas

+ const AlterConfigs

+ const AlterPartition

+ const AlterPartitionAssignments

+ const AlterReplicaLogDirs

+ const AlterUserSCRAMCredentials

+ const ApiVersions

+ const BeginQuorumEpoch

+ const BrokerHeartbeat

+ const BrokerRegistration

+ const ControlledShutdown

+ const CreateACLs

+ const CreateDelegationToken

+ const CreatePartitions

+ const CreateTopics

+ const DeleteACLs

+ const DeleteGroups

+ const DeleteRecords

+ const DeleteTopics

+ const DescribeACLs

+ const DescribeClientQuotas

+ const DescribeCluster

+ const DescribeConfigs

+ const DescribeDelegationToken

+ const DescribeGroups

+ const DescribeLogDirs

+ const DescribeProducers

+ const DescribeQuorum

+ const DescribeTransactions

+ const DescribeUserSCRAMCredentials

+ const ElectLeaders

+ const EndQuorumEpoch

+ const EndTxn

+ const Envelope

+ const ExpireDelegationToken

+ const Fetch

+ const FetchSnapshot

+ const FindCoordinator

+ const Heartbeat

+ const IncrementalAlterConfigs

+ const InitProducerID

+ const JoinGroup

+ const LeaderAndISR

+ const LeaveGroup

+ const ListGroups

+ const ListOffsets

+ const ListPartitionReassignments

+ const ListTransactions

+ const Metadata

+ const OffsetCommit

+ const OffsetDelete

+ const OffsetFetch

+ const OffsetForLeaderEpoch

+ const Produce

+ const RenewDelegationToken

+ const SASLAuthenticate

+ const SASLHandshake

+ const StopReplica

+ const SyncGroup

+ const TxnOffsetCommit

+ const UnregisterBroker

+ const UpdateFeatures

+ const UpdateMetadata

+ const Vote

+ const WriteTxnMarkers

+ func (k Key) Int16() int16

+ func (k Key) Name() string

+ func (k Key) Request() Request

+ func (k Key) Response() Response

+ type LeaderAndISRRequest struct

+ BrokerEpoch int64

+ ControllerEpoch int32

+ ControllerID int32

+ LiveLeaders []LeaderAndISRRequestLiveLeader

+ PartitionStates []LeaderAndISRRequestTopicPartition

+ TopicStates []LeaderAndISRRequestTopicState

+ Type int8

+ UnknownTags Tags

+ Version int16

+ func NewLeaderAndISRRequest() LeaderAndISRRequest

+ func NewPtrLeaderAndISRRequest() *LeaderAndISRRequest

+ func (*LeaderAndISRRequest) Key() int16

+ func (*LeaderAndISRRequest) MaxVersion() int16

+ func (v *LeaderAndISRRequest) AppendTo(dst []byte) []byte

+ func (v *LeaderAndISRRequest) Default()

+ func (v *LeaderAndISRRequest) GetVersion() int16

+ func (v *LeaderAndISRRequest) IsFlexible() bool

+ func (v *LeaderAndISRRequest) ReadFrom(src []byte) error

+ func (v *LeaderAndISRRequest) RequestWith(ctx context.Context, r Requestor) (*LeaderAndISRResponse, error)

+ func (v *LeaderAndISRRequest) ResponseKind() Response

+ func (v *LeaderAndISRRequest) SetVersion(version int16)

+ type LeaderAndISRRequestLiveLeader struct

+ BrokerID int32

+ Host string

+ Port int32

+ UnknownTags Tags

+ func NewLeaderAndISRRequestLiveLeader() LeaderAndISRRequestLiveLeader

+ func (v *LeaderAndISRRequestLiveLeader) Default()

+ type LeaderAndISRRequestTopicPartition struct

+ AddingReplicas []int32

+ ControllerEpoch int32

+ ISR []int32

+ IsNew bool

+ Leader int32

+ LeaderEpoch int32

+ LeaderRecoveryState int8

+ Partition int32

+ RemovingReplicas []int32

+ Replicas []int32

+ Topic string

+ UnknownTags Tags

+ ZKVersion int32

+ func NewLeaderAndISRRequestTopicPartition() LeaderAndISRRequestTopicPartition

+ func (v *LeaderAndISRRequestTopicPartition) Default()

+ type LeaderAndISRRequestTopicState struct

+ PartitionStates []LeaderAndISRRequestTopicPartition

+ Topic string

+ TopicID [16]byte

+ UnknownTags Tags

+ func NewLeaderAndISRRequestTopicState() LeaderAndISRRequestTopicState

+ func (v *LeaderAndISRRequestTopicState) Default()

+ type LeaderAndISRResponse struct

+ ErrorCode int16

+ Partitions []LeaderAndISRResponseTopicPartition

+ Topics []LeaderAndISRResponseTopic

+ UnknownTags Tags

+ Version int16

+ func NewLeaderAndISRResponse() LeaderAndISRResponse

+ func NewPtrLeaderAndISRResponse() *LeaderAndISRResponse

+ func (*LeaderAndISRResponse) Key() int16

+ func (*LeaderAndISRResponse) MaxVersion() int16

+ func (v *LeaderAndISRResponse) AppendTo(dst []byte) []byte

+ func (v *LeaderAndISRResponse) Default()

+ func (v *LeaderAndISRResponse) GetVersion() int16

+ func (v *LeaderAndISRResponse) IsFlexible() bool

+ func (v *LeaderAndISRResponse) ReadFrom(src []byte) error

+ func (v *LeaderAndISRResponse) RequestKind() Request

+ func (v *LeaderAndISRResponse) SetVersion(version int16)

+ type LeaderAndISRResponseTopic struct

+ Partitions []LeaderAndISRResponseTopicPartition

+ TopicID [16]byte

+ UnknownTags Tags

+ func NewLeaderAndISRResponseTopic() LeaderAndISRResponseTopic

+ func (v *LeaderAndISRResponseTopic) Default()

+ type LeaderAndISRResponseTopicPartition struct

+ ErrorCode int16

+ Partition int32

+ Topic string

+ UnknownTags Tags

+ func NewLeaderAndISRResponseTopicPartition() LeaderAndISRResponseTopicPartition

+ func (v *LeaderAndISRResponseTopicPartition) Default()

+ type LeaderChangeMessage struct

+ GrantingVoters []LeaderChangeMessageVoter

+ LeaderID int32

+ UnknownTags Tags

+ Version int16

+ Voters []LeaderChangeMessageVoter

+ func NewLeaderChangeMessage() LeaderChangeMessage

+ func (v *LeaderChangeMessage) AppendTo(dst []byte) []byte

+ func (v *LeaderChangeMessage) Default()

+ func (v *LeaderChangeMessage) IsFlexible() bool

+ func (v *LeaderChangeMessage) ReadFrom(src []byte) error

+ type LeaderChangeMessageVoter struct

+ UnknownTags Tags

+ VoterID int32

+ func NewLeaderChangeMessageVoter() LeaderChangeMessageVoter

+ func (v *LeaderChangeMessageVoter) Default()

+ type LeaveGroupRequest struct

+ Group string

+ MemberID string

+ Members []LeaveGroupRequestMember

+ UnknownTags Tags

+ Version int16

+ func NewLeaveGroupRequest() LeaveGroupRequest

+ func NewPtrLeaveGroupRequest() *LeaveGroupRequest

+ func (*LeaveGroupRequest) Key() int16

+ func (*LeaveGroupRequest) MaxVersion() int16

+ func (v *LeaveGroupRequest) AppendTo(dst []byte) []byte

+ func (v *LeaveGroupRequest) Default()

+ func (v *LeaveGroupRequest) GetVersion() int16

+ func (v *LeaveGroupRequest) IsFlexible() bool

+ func (v *LeaveGroupRequest) IsGroupCoordinatorRequest()

+ func (v *LeaveGroupRequest) ReadFrom(src []byte) error

+ func (v *LeaveGroupRequest) RequestWith(ctx context.Context, r Requestor) (*LeaveGroupResponse, error)

+ func (v *LeaveGroupRequest) ResponseKind() Response

+ func (v *LeaveGroupRequest) SetVersion(version int16)

+ type LeaveGroupRequestMember struct

+ InstanceID *string

+ MemberID string

+ Reason *string

+ UnknownTags Tags

+ func NewLeaveGroupRequestMember() LeaveGroupRequestMember

+ func (v *LeaveGroupRequestMember) Default()

+ type LeaveGroupResponse struct

+ ErrorCode int16

+ Members []LeaveGroupResponseMember

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewLeaveGroupResponse() LeaveGroupResponse

+ func NewPtrLeaveGroupResponse() *LeaveGroupResponse

+ func (*LeaveGroupResponse) Key() int16

+ func (*LeaveGroupResponse) MaxVersion() int16

+ func (v *LeaveGroupResponse) AppendTo(dst []byte) []byte

+ func (v *LeaveGroupResponse) Default()

+ func (v *LeaveGroupResponse) GetVersion() int16

+ func (v *LeaveGroupResponse) IsFlexible() bool

+ func (v *LeaveGroupResponse) ReadFrom(src []byte) error

+ func (v *LeaveGroupResponse) RequestKind() Request

+ func (v *LeaveGroupResponse) SetVersion(version int16)

+ func (v *LeaveGroupResponse) Throttle() (int32, bool)

+ type LeaveGroupResponseMember struct

+ ErrorCode int16

+ InstanceID *string

+ MemberID string

+ UnknownTags Tags

+ func NewLeaveGroupResponseMember() LeaveGroupResponseMember

+ func (v *LeaveGroupResponseMember) Default()

+ type ListGroupsRequest struct

+ StatesFilter []string

+ UnknownTags Tags

+ Version int16

+ func NewListGroupsRequest() ListGroupsRequest

+ func NewPtrListGroupsRequest() *ListGroupsRequest

+ func (*ListGroupsRequest) Key() int16

+ func (*ListGroupsRequest) MaxVersion() int16

+ func (v *ListGroupsRequest) AppendTo(dst []byte) []byte

+ func (v *ListGroupsRequest) Default()

+ func (v *ListGroupsRequest) GetVersion() int16

+ func (v *ListGroupsRequest) IsFlexible() bool

+ func (v *ListGroupsRequest) ReadFrom(src []byte) error

+ func (v *ListGroupsRequest) RequestWith(ctx context.Context, r Requestor) (*ListGroupsResponse, error)

+ func (v *ListGroupsRequest) ResponseKind() Response

+ func (v *ListGroupsRequest) SetVersion(version int16)

+ type ListGroupsResponse struct

+ ErrorCode int16

+ Groups []ListGroupsResponseGroup

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewListGroupsResponse() ListGroupsResponse

+ func NewPtrListGroupsResponse() *ListGroupsResponse

+ func (*ListGroupsResponse) Key() int16

+ func (*ListGroupsResponse) MaxVersion() int16

+ func (v *ListGroupsResponse) AppendTo(dst []byte) []byte

+ func (v *ListGroupsResponse) Default()

+ func (v *ListGroupsResponse) GetVersion() int16

+ func (v *ListGroupsResponse) IsFlexible() bool

+ func (v *ListGroupsResponse) ReadFrom(src []byte) error

+ func (v *ListGroupsResponse) RequestKind() Request

+ func (v *ListGroupsResponse) SetVersion(version int16)

+ func (v *ListGroupsResponse) Throttle() (int32, bool)

+ type ListGroupsResponseGroup struct

+ Group string

+ GroupState string

+ ProtocolType string

+ UnknownTags Tags

+ func NewListGroupsResponseGroup() ListGroupsResponseGroup

+ func (v *ListGroupsResponseGroup) Default()

+ type ListOffsetsRequest struct

+ IsolationLevel int8

+ ReplicaID int32

+ Topics []ListOffsetsRequestTopic

+ UnknownTags Tags

+ Version int16

+ func NewListOffsetsRequest() ListOffsetsRequest

+ func NewPtrListOffsetsRequest() *ListOffsetsRequest

+ func (*ListOffsetsRequest) Key() int16

+ func (*ListOffsetsRequest) MaxVersion() int16

+ func (v *ListOffsetsRequest) AppendTo(dst []byte) []byte

+ func (v *ListOffsetsRequest) Default()

+ func (v *ListOffsetsRequest) GetVersion() int16

+ func (v *ListOffsetsRequest) IsFlexible() bool

+ func (v *ListOffsetsRequest) ReadFrom(src []byte) error

+ func (v *ListOffsetsRequest) RequestWith(ctx context.Context, r Requestor) (*ListOffsetsResponse, error)

+ func (v *ListOffsetsRequest) ResponseKind() Response

+ func (v *ListOffsetsRequest) SetVersion(version int16)

+ type ListOffsetsRequestTopic struct

+ Partitions []ListOffsetsRequestTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewListOffsetsRequestTopic() ListOffsetsRequestTopic

+ func (v *ListOffsetsRequestTopic) Default()

+ type ListOffsetsRequestTopicPartition struct

+ CurrentLeaderEpoch int32

+ MaxNumOffsets int32

+ Partition int32

+ Timestamp int64

+ UnknownTags Tags

+ func NewListOffsetsRequestTopicPartition() ListOffsetsRequestTopicPartition

+ func (v *ListOffsetsRequestTopicPartition) Default()

+ type ListOffsetsResponse struct

+ ThrottleMillis int32

+ Topics []ListOffsetsResponseTopic

+ UnknownTags Tags

+ Version int16

+ func NewListOffsetsResponse() ListOffsetsResponse

+ func NewPtrListOffsetsResponse() *ListOffsetsResponse

+ func (*ListOffsetsResponse) Key() int16

+ func (*ListOffsetsResponse) MaxVersion() int16

+ func (v *ListOffsetsResponse) AppendTo(dst []byte) []byte

+ func (v *ListOffsetsResponse) Default()

+ func (v *ListOffsetsResponse) GetVersion() int16

+ func (v *ListOffsetsResponse) IsFlexible() bool

+ func (v *ListOffsetsResponse) ReadFrom(src []byte) error

+ func (v *ListOffsetsResponse) RequestKind() Request

+ func (v *ListOffsetsResponse) SetVersion(version int16)

+ func (v *ListOffsetsResponse) Throttle() (int32, bool)

+ type ListOffsetsResponseTopic struct

+ Partitions []ListOffsetsResponseTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewListOffsetsResponseTopic() ListOffsetsResponseTopic

+ func (v *ListOffsetsResponseTopic) Default()

+ type ListOffsetsResponseTopicPartition struct

+ ErrorCode int16

+ LeaderEpoch int32

+ Offset int64

+ OldStyleOffsets []int64

+ Partition int32

+ Timestamp int64

+ UnknownTags Tags

+ func NewListOffsetsResponseTopicPartition() ListOffsetsResponseTopicPartition

+ func (v *ListOffsetsResponseTopicPartition) Default()

+ type ListPartitionReassignmentsRequest struct

+ TimeoutMillis int32

+ Topics []ListPartitionReassignmentsRequestTopic

+ UnknownTags Tags

+ Version int16

+ func NewListPartitionReassignmentsRequest() ListPartitionReassignmentsRequest

+ func NewPtrListPartitionReassignmentsRequest() *ListPartitionReassignmentsRequest

+ func (*ListPartitionReassignmentsRequest) Key() int16

+ func (*ListPartitionReassignmentsRequest) MaxVersion() int16

+ func (v *ListPartitionReassignmentsRequest) AppendTo(dst []byte) []byte

+ func (v *ListPartitionReassignmentsRequest) Default()

+ func (v *ListPartitionReassignmentsRequest) GetVersion() int16

+ func (v *ListPartitionReassignmentsRequest) IsAdminRequest()

+ func (v *ListPartitionReassignmentsRequest) IsFlexible() bool

+ func (v *ListPartitionReassignmentsRequest) ReadFrom(src []byte) error

+ func (v *ListPartitionReassignmentsRequest) RequestWith(ctx context.Context, r Requestor) (*ListPartitionReassignmentsResponse, error)

+ func (v *ListPartitionReassignmentsRequest) ResponseKind() Response

+ func (v *ListPartitionReassignmentsRequest) SetVersion(version int16)

+ func (v *ListPartitionReassignmentsRequest) Timeout() int32

+ type ListPartitionReassignmentsRequestTopic struct

+ Partitions []int32

+ Topic string

+ UnknownTags Tags

+ func NewListPartitionReassignmentsRequestTopic() ListPartitionReassignmentsRequestTopic

+ func (v *ListPartitionReassignmentsRequestTopic) Default()

+ type ListPartitionReassignmentsResponse struct

+ ErrorCode int16

+ ErrorMessage *string

+ ThrottleMillis int32

+ Topics []ListPartitionReassignmentsResponseTopic

+ UnknownTags Tags

+ Version int16

+ func NewListPartitionReassignmentsResponse() ListPartitionReassignmentsResponse

+ func NewPtrListPartitionReassignmentsResponse() *ListPartitionReassignmentsResponse

+ func (*ListPartitionReassignmentsResponse) Key() int16

+ func (*ListPartitionReassignmentsResponse) MaxVersion() int16

+ func (v *ListPartitionReassignmentsResponse) AppendTo(dst []byte) []byte

+ func (v *ListPartitionReassignmentsResponse) Default()

+ func (v *ListPartitionReassignmentsResponse) GetVersion() int16

+ func (v *ListPartitionReassignmentsResponse) IsFlexible() bool

+ func (v *ListPartitionReassignmentsResponse) ReadFrom(src []byte) error

+ func (v *ListPartitionReassignmentsResponse) RequestKind() Request

+ func (v *ListPartitionReassignmentsResponse) SetVersion(version int16)

+ func (v *ListPartitionReassignmentsResponse) Throttle() (int32, bool)

+ type ListPartitionReassignmentsResponseTopic struct

+ Partitions []ListPartitionReassignmentsResponseTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewListPartitionReassignmentsResponseTopic() ListPartitionReassignmentsResponseTopic

+ func (v *ListPartitionReassignmentsResponseTopic) Default()

+ type ListPartitionReassignmentsResponseTopicPartition struct

+ AddingReplicas []int32

+ Partition int32

+ RemovingReplicas []int32

+ Replicas []int32

+ UnknownTags Tags

+ func NewListPartitionReassignmentsResponseTopicPartition() ListPartitionReassignmentsResponseTopicPartition

+ func (v *ListPartitionReassignmentsResponseTopicPartition) Default()

+ type ListTransactionsRequest struct

+ ProducerIDFilters []int64

+ StateFilters []string

+ UnknownTags Tags

+ Version int16

+ func NewListTransactionsRequest() ListTransactionsRequest

+ func NewPtrListTransactionsRequest() *ListTransactionsRequest

+ func (*ListTransactionsRequest) Key() int16

+ func (*ListTransactionsRequest) MaxVersion() int16

+ func (v *ListTransactionsRequest) AppendTo(dst []byte) []byte

+ func (v *ListTransactionsRequest) Default()

+ func (v *ListTransactionsRequest) GetVersion() int16

+ func (v *ListTransactionsRequest) IsFlexible() bool

+ func (v *ListTransactionsRequest) ReadFrom(src []byte) error

+ func (v *ListTransactionsRequest) RequestWith(ctx context.Context, r Requestor) (*ListTransactionsResponse, error)

+ func (v *ListTransactionsRequest) ResponseKind() Response

+ func (v *ListTransactionsRequest) SetVersion(version int16)

+ type ListTransactionsResponse struct

+ ErrorCode int16

+ ThrottleMillis int32

+ TransactionStates []ListTransactionsResponseTransactionState

+ UnknownStateFilters []string

+ UnknownTags Tags

+ Version int16

+ func NewListTransactionsResponse() ListTransactionsResponse

+ func NewPtrListTransactionsResponse() *ListTransactionsResponse

+ func (*ListTransactionsResponse) Key() int16

+ func (*ListTransactionsResponse) MaxVersion() int16

+ func (v *ListTransactionsResponse) AppendTo(dst []byte) []byte

+ func (v *ListTransactionsResponse) Default()

+ func (v *ListTransactionsResponse) GetVersion() int16

+ func (v *ListTransactionsResponse) IsFlexible() bool

+ func (v *ListTransactionsResponse) ReadFrom(src []byte) error

+ func (v *ListTransactionsResponse) RequestKind() Request

+ func (v *ListTransactionsResponse) SetVersion(version int16)

+ func (v *ListTransactionsResponse) Throttle() (int32, bool)

+ type ListTransactionsResponseTransactionState struct

+ ProducerID int64

+ TransactionState string

+ TransactionalID string

+ UnknownTags Tags

+ func NewListTransactionsResponseTransactionState() ListTransactionsResponseTransactionState

+ func (v *ListTransactionsResponseTransactionState) Default()

+ type MessageV0 struct

+ Attributes int8

+ CRC int32

+ Key []byte

+ Magic int8

+ MessageSize int32

+ Offset int64

+ Value []byte

+ func NewMessageV0() MessageV0

+ func (v *MessageV0) AppendTo(dst []byte) []byte

+ func (v *MessageV0) Default()

+ func (v *MessageV0) ReadFrom(src []byte) error

+ type MessageV1 struct

+ Attributes int8

+ CRC int32

+ Key []byte

+ Magic int8

+ MessageSize int32

+ Offset int64

+ Timestamp int64

+ Value []byte

+ func NewMessageV1() MessageV1

+ func (v *MessageV1) AppendTo(dst []byte) []byte

+ func (v *MessageV1) Default()

+ func (v *MessageV1) ReadFrom(src []byte) error

+ type MetadataRequest struct

+ AllowAutoTopicCreation bool

+ IncludeClusterAuthorizedOperations bool

+ IncludeTopicAuthorizedOperations bool

+ Topics []MetadataRequestTopic

+ UnknownTags Tags

+ Version int16

+ func NewMetadataRequest() MetadataRequest

+ func NewPtrMetadataRequest() *MetadataRequest

+ func (*MetadataRequest) Key() int16

+ func (*MetadataRequest) MaxVersion() int16

+ func (v *MetadataRequest) AppendTo(dst []byte) []byte

+ func (v *MetadataRequest) Default()

+ func (v *MetadataRequest) GetVersion() int16

+ func (v *MetadataRequest) IsFlexible() bool

+ func (v *MetadataRequest) ReadFrom(src []byte) error

+ func (v *MetadataRequest) RequestWith(ctx context.Context, r Requestor) (*MetadataResponse, error)

+ func (v *MetadataRequest) ResponseKind() Response

+ func (v *MetadataRequest) SetVersion(version int16)

+ type MetadataRequestTopic struct

+ Topic *string

+ TopicID [16]byte

+ UnknownTags Tags

+ func NewMetadataRequestTopic() MetadataRequestTopic

+ func (v *MetadataRequestTopic) Default()

+ type MetadataResponse struct

+ AuthorizedOperations int32

+ Brokers []MetadataResponseBroker

+ ClusterID *string

+ ControllerID int32

+ ThrottleMillis int32

+ Topics []MetadataResponseTopic

+ UnknownTags Tags

+ Version int16

+ func NewMetadataResponse() MetadataResponse

+ func NewPtrMetadataResponse() *MetadataResponse

+ func (*MetadataResponse) Key() int16

+ func (*MetadataResponse) MaxVersion() int16

+ func (v *MetadataResponse) AppendTo(dst []byte) []byte

+ func (v *MetadataResponse) Default()

+ func (v *MetadataResponse) GetVersion() int16

+ func (v *MetadataResponse) IsFlexible() bool

+ func (v *MetadataResponse) ReadFrom(src []byte) error

+ func (v *MetadataResponse) RequestKind() Request

+ func (v *MetadataResponse) SetVersion(version int16)

+ func (v *MetadataResponse) Throttle() (int32, bool)

+ type MetadataResponseBroker struct

+ Host string

+ NodeID int32

+ Port int32

+ Rack *string

+ UnknownTags Tags

+ func NewMetadataResponseBroker() MetadataResponseBroker

+ func (v *MetadataResponseBroker) Default()

+ type MetadataResponseTopic struct

+ AuthorizedOperations int32

+ ErrorCode int16

+ IsInternal bool

+ Partitions []MetadataResponseTopicPartition

+ Topic *string

+ TopicID [16]byte

+ UnknownTags Tags

+ func NewMetadataResponseTopic() MetadataResponseTopic

+ func (v *MetadataResponseTopic) Default()

+ type MetadataResponseTopicPartition struct

+ ErrorCode int16

+ ISR []int32

+ Leader int32

+ LeaderEpoch int32

+ OfflineReplicas []int32

+ Partition int32

+ Replicas []int32

+ UnknownTags Tags

+ func NewMetadataResponseTopicPartition() MetadataResponseTopicPartition

+ func (v *MetadataResponseTopicPartition) Default()

+ type OffsetCommitKey struct

+ Group string

+ Partition int32

+ Topic string

+ Version int16

+ func NewOffsetCommitKey() OffsetCommitKey

+ func (v *OffsetCommitKey) AppendTo(dst []byte) []byte

+ func (v *OffsetCommitKey) Default()

+ func (v *OffsetCommitKey) ReadFrom(src []byte) error

+ type OffsetCommitRequest struct

+ Generation int32

+ Group string

+ InstanceID *string

+ MemberID string

+ RetentionTimeMillis int64

+ Topics []OffsetCommitRequestTopic

+ UnknownTags Tags

+ Version int16

+ func NewOffsetCommitRequest() OffsetCommitRequest

+ func NewPtrOffsetCommitRequest() *OffsetCommitRequest

+ func (*OffsetCommitRequest) Key() int16

+ func (*OffsetCommitRequest) MaxVersion() int16

+ func (v *OffsetCommitRequest) AppendTo(dst []byte) []byte

+ func (v *OffsetCommitRequest) Default()

+ func (v *OffsetCommitRequest) GetVersion() int16

+ func (v *OffsetCommitRequest) IsFlexible() bool

+ func (v *OffsetCommitRequest) IsGroupCoordinatorRequest()

+ func (v *OffsetCommitRequest) ReadFrom(src []byte) error

+ func (v *OffsetCommitRequest) RequestWith(ctx context.Context, r Requestor) (*OffsetCommitResponse, error)

+ func (v *OffsetCommitRequest) ResponseKind() Response

+ func (v *OffsetCommitRequest) SetVersion(version int16)

+ type OffsetCommitRequestTopic struct

+ Partitions []OffsetCommitRequestTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewOffsetCommitRequestTopic() OffsetCommitRequestTopic

+ func (v *OffsetCommitRequestTopic) Default()

+ type OffsetCommitRequestTopicPartition struct

+ LeaderEpoch int32

+ Metadata *string

+ Offset int64

+ Partition int32

+ Timestamp int64

+ UnknownTags Tags

+ func NewOffsetCommitRequestTopicPartition() OffsetCommitRequestTopicPartition

+ func (v *OffsetCommitRequestTopicPartition) Default()

+ type OffsetCommitResponse struct

+ ThrottleMillis int32

+ Topics []OffsetCommitResponseTopic

+ UnknownTags Tags

+ Version int16

+ func NewOffsetCommitResponse() OffsetCommitResponse

+ func NewPtrOffsetCommitResponse() *OffsetCommitResponse

+ func (*OffsetCommitResponse) Key() int16

+ func (*OffsetCommitResponse) MaxVersion() int16

+ func (v *OffsetCommitResponse) AppendTo(dst []byte) []byte

+ func (v *OffsetCommitResponse) Default()

+ func (v *OffsetCommitResponse) GetVersion() int16

+ func (v *OffsetCommitResponse) IsFlexible() bool

+ func (v *OffsetCommitResponse) ReadFrom(src []byte) error

+ func (v *OffsetCommitResponse) RequestKind() Request

+ func (v *OffsetCommitResponse) SetVersion(version int16)

+ func (v *OffsetCommitResponse) Throttle() (int32, bool)

+ type OffsetCommitResponseTopic struct

+ Partitions []OffsetCommitResponseTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewOffsetCommitResponseTopic() OffsetCommitResponseTopic

+ func (v *OffsetCommitResponseTopic) Default()

+ type OffsetCommitResponseTopicPartition struct

+ ErrorCode int16

+ Partition int32

+ UnknownTags Tags

+ func NewOffsetCommitResponseTopicPartition() OffsetCommitResponseTopicPartition

+ func (v *OffsetCommitResponseTopicPartition) Default()

+ type OffsetCommitValue struct

+ CommitTimestamp int64

+ ExpireTimestamp int64

+ LeaderEpoch int32

+ Metadata string

+ Offset int64

+ Version int16

+ func NewOffsetCommitValue() OffsetCommitValue

+ func (v *OffsetCommitValue) AppendTo(dst []byte) []byte

+ func (v *OffsetCommitValue) Default()

+ func (v *OffsetCommitValue) ReadFrom(src []byte) error

+ type OffsetDeleteRequest struct

+ Group string

+ Topics []OffsetDeleteRequestTopic

+ Version int16

+ func NewOffsetDeleteRequest() OffsetDeleteRequest

+ func NewPtrOffsetDeleteRequest() *OffsetDeleteRequest

+ func (*OffsetDeleteRequest) Key() int16

+ func (*OffsetDeleteRequest) MaxVersion() int16

+ func (v *OffsetDeleteRequest) AppendTo(dst []byte) []byte

+ func (v *OffsetDeleteRequest) Default()

+ func (v *OffsetDeleteRequest) GetVersion() int16

+ func (v *OffsetDeleteRequest) IsFlexible() bool

+ func (v *OffsetDeleteRequest) IsGroupCoordinatorRequest()

+ func (v *OffsetDeleteRequest) ReadFrom(src []byte) error

+ func (v *OffsetDeleteRequest) RequestWith(ctx context.Context, r Requestor) (*OffsetDeleteResponse, error)

+ func (v *OffsetDeleteRequest) ResponseKind() Response

+ func (v *OffsetDeleteRequest) SetVersion(version int16)

+ type OffsetDeleteRequestTopic struct

+ Partitions []OffsetDeleteRequestTopicPartition

+ Topic string

+ func NewOffsetDeleteRequestTopic() OffsetDeleteRequestTopic

+ func (v *OffsetDeleteRequestTopic) Default()

+ type OffsetDeleteRequestTopicPartition struct

+ Partition int32

+ func NewOffsetDeleteRequestTopicPartition() OffsetDeleteRequestTopicPartition

+ func (v *OffsetDeleteRequestTopicPartition) Default()

+ type OffsetDeleteResponse struct

+ ErrorCode int16

+ ThrottleMillis int32

+ Topics []OffsetDeleteResponseTopic

+ Version int16

+ func NewOffsetDeleteResponse() OffsetDeleteResponse

+ func NewPtrOffsetDeleteResponse() *OffsetDeleteResponse

+ func (*OffsetDeleteResponse) Key() int16

+ func (*OffsetDeleteResponse) MaxVersion() int16

+ func (v *OffsetDeleteResponse) AppendTo(dst []byte) []byte

+ func (v *OffsetDeleteResponse) Default()

+ func (v *OffsetDeleteResponse) GetVersion() int16

+ func (v *OffsetDeleteResponse) IsFlexible() bool

+ func (v *OffsetDeleteResponse) ReadFrom(src []byte) error

+ func (v *OffsetDeleteResponse) RequestKind() Request

+ func (v *OffsetDeleteResponse) SetVersion(version int16)

+ func (v *OffsetDeleteResponse) Throttle() (int32, bool)

+ type OffsetDeleteResponseTopic struct

+ Partitions []OffsetDeleteResponseTopicPartition

+ Topic string

+ func NewOffsetDeleteResponseTopic() OffsetDeleteResponseTopic

+ func (v *OffsetDeleteResponseTopic) Default()

+ type OffsetDeleteResponseTopicPartition struct

+ ErrorCode int16

+ Partition int32

+ func NewOffsetDeleteResponseTopicPartition() OffsetDeleteResponseTopicPartition

+ func (v *OffsetDeleteResponseTopicPartition) Default()

+ type OffsetFetchRequest struct

+ Group string

+ Groups []OffsetFetchRequestGroup

+ RequireStable bool

+ Topics []OffsetFetchRequestTopic

+ UnknownTags Tags

+ Version int16

+ func NewOffsetFetchRequest() OffsetFetchRequest

+ func NewPtrOffsetFetchRequest() *OffsetFetchRequest

+ func (*OffsetFetchRequest) Key() int16

+ func (*OffsetFetchRequest) MaxVersion() int16

+ func (v *OffsetFetchRequest) AppendTo(dst []byte) []byte

+ func (v *OffsetFetchRequest) Default()

+ func (v *OffsetFetchRequest) GetVersion() int16

+ func (v *OffsetFetchRequest) IsFlexible() bool

+ func (v *OffsetFetchRequest) IsGroupCoordinatorRequest()

+ func (v *OffsetFetchRequest) ReadFrom(src []byte) error

+ func (v *OffsetFetchRequest) RequestWith(ctx context.Context, r Requestor) (*OffsetFetchResponse, error)

+ func (v *OffsetFetchRequest) ResponseKind() Response

+ func (v *OffsetFetchRequest) SetVersion(version int16)

+ type OffsetFetchRequestGroup struct

+ Group string

+ Topics []OffsetFetchRequestGroupTopic

+ UnknownTags Tags

+ func NewOffsetFetchRequestGroup() OffsetFetchRequestGroup

+ func (v *OffsetFetchRequestGroup) Default()

+ type OffsetFetchRequestGroupTopic struct

+ Partitions []int32

+ Topic string

+ UnknownTags Tags

+ func NewOffsetFetchRequestGroupTopic() OffsetFetchRequestGroupTopic

+ func (v *OffsetFetchRequestGroupTopic) Default()

+ type OffsetFetchRequestTopic struct

+ Partitions []int32

+ Topic string

+ UnknownTags Tags

+ func NewOffsetFetchRequestTopic() OffsetFetchRequestTopic

+ func (v *OffsetFetchRequestTopic) Default()

+ type OffsetFetchResponse struct

+ ErrorCode int16

+ Groups []OffsetFetchResponseGroup

+ ThrottleMillis int32

+ Topics []OffsetFetchResponseTopic

+ UnknownTags Tags

+ Version int16

+ func NewOffsetFetchResponse() OffsetFetchResponse

+ func NewPtrOffsetFetchResponse() *OffsetFetchResponse

+ func (*OffsetFetchResponse) Key() int16

+ func (*OffsetFetchResponse) MaxVersion() int16

+ func (v *OffsetFetchResponse) AppendTo(dst []byte) []byte

+ func (v *OffsetFetchResponse) Default()

+ func (v *OffsetFetchResponse) GetVersion() int16

+ func (v *OffsetFetchResponse) IsFlexible() bool

+ func (v *OffsetFetchResponse) ReadFrom(src []byte) error

+ func (v *OffsetFetchResponse) RequestKind() Request

+ func (v *OffsetFetchResponse) SetVersion(version int16)

+ func (v *OffsetFetchResponse) Throttle() (int32, bool)

+ type OffsetFetchResponseGroup struct

+ ErrorCode int16

+ Group string

+ Topics []OffsetFetchResponseGroupTopic

+ UnknownTags Tags

+ func NewOffsetFetchResponseGroup() OffsetFetchResponseGroup

+ func (v *OffsetFetchResponseGroup) Default()

+ type OffsetFetchResponseGroupTopic struct

+ Partitions []OffsetFetchResponseGroupTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewOffsetFetchResponseGroupTopic() OffsetFetchResponseGroupTopic

+ func (v *OffsetFetchResponseGroupTopic) Default()

+ type OffsetFetchResponseGroupTopicPartition struct

+ ErrorCode int16

+ LeaderEpoch int32

+ Metadata *string

+ Offset int64

+ Partition int32

+ UnknownTags Tags

+ func NewOffsetFetchResponseGroupTopicPartition() OffsetFetchResponseGroupTopicPartition

+ func (v *OffsetFetchResponseGroupTopicPartition) Default()

+ type OffsetFetchResponseTopic struct

+ Partitions []OffsetFetchResponseTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewOffsetFetchResponseTopic() OffsetFetchResponseTopic

+ func (v *OffsetFetchResponseTopic) Default()

+ type OffsetFetchResponseTopicPartition struct

+ ErrorCode int16

+ LeaderEpoch int32

+ Metadata *string

+ Offset int64

+ Partition int32

+ UnknownTags Tags

+ func NewOffsetFetchResponseTopicPartition() OffsetFetchResponseTopicPartition

+ func (v *OffsetFetchResponseTopicPartition) Default()

+ type OffsetForLeaderEpochRequest struct

+ ReplicaID int32

+ Topics []OffsetForLeaderEpochRequestTopic

+ UnknownTags Tags

+ Version int16

+ func NewOffsetForLeaderEpochRequest() OffsetForLeaderEpochRequest

+ func NewPtrOffsetForLeaderEpochRequest() *OffsetForLeaderEpochRequest

+ func (*OffsetForLeaderEpochRequest) Key() int16

+ func (*OffsetForLeaderEpochRequest) MaxVersion() int16

+ func (v *OffsetForLeaderEpochRequest) AppendTo(dst []byte) []byte

+ func (v *OffsetForLeaderEpochRequest) Default()

+ func (v *OffsetForLeaderEpochRequest) GetVersion() int16

+ func (v *OffsetForLeaderEpochRequest) IsFlexible() bool

+ func (v *OffsetForLeaderEpochRequest) ReadFrom(src []byte) error

+ func (v *OffsetForLeaderEpochRequest) RequestWith(ctx context.Context, r Requestor) (*OffsetForLeaderEpochResponse, error)

+ func (v *OffsetForLeaderEpochRequest) ResponseKind() Response

+ func (v *OffsetForLeaderEpochRequest) SetVersion(version int16)

+ type OffsetForLeaderEpochRequestTopic struct

+ Partitions []OffsetForLeaderEpochRequestTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewOffsetForLeaderEpochRequestTopic() OffsetForLeaderEpochRequestTopic

+ func (v *OffsetForLeaderEpochRequestTopic) Default()

+ type OffsetForLeaderEpochRequestTopicPartition struct

+ CurrentLeaderEpoch int32

+ LeaderEpoch int32

+ Partition int32

+ UnknownTags Tags

+ func NewOffsetForLeaderEpochRequestTopicPartition() OffsetForLeaderEpochRequestTopicPartition

+ func (v *OffsetForLeaderEpochRequestTopicPartition) Default()

+ type OffsetForLeaderEpochResponse struct

+ ThrottleMillis int32

+ Topics []OffsetForLeaderEpochResponseTopic

+ UnknownTags Tags

+ Version int16

+ func NewOffsetForLeaderEpochResponse() OffsetForLeaderEpochResponse

+ func NewPtrOffsetForLeaderEpochResponse() *OffsetForLeaderEpochResponse

+ func (*OffsetForLeaderEpochResponse) Key() int16

+ func (*OffsetForLeaderEpochResponse) MaxVersion() int16

+ func (v *OffsetForLeaderEpochResponse) AppendTo(dst []byte) []byte

+ func (v *OffsetForLeaderEpochResponse) Default()

+ func (v *OffsetForLeaderEpochResponse) GetVersion() int16

+ func (v *OffsetForLeaderEpochResponse) IsFlexible() bool

+ func (v *OffsetForLeaderEpochResponse) ReadFrom(src []byte) error

+ func (v *OffsetForLeaderEpochResponse) RequestKind() Request

+ func (v *OffsetForLeaderEpochResponse) SetVersion(version int16)

+ func (v *OffsetForLeaderEpochResponse) Throttle() (int32, bool)

+ type OffsetForLeaderEpochResponseTopic struct

+ Partitions []OffsetForLeaderEpochResponseTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewOffsetForLeaderEpochResponseTopic() OffsetForLeaderEpochResponseTopic

+ func (v *OffsetForLeaderEpochResponseTopic) Default()

+ type OffsetForLeaderEpochResponseTopicPartition struct

+ EndOffset int64

+ ErrorCode int16

+ LeaderEpoch int32

+ Partition int32

+ UnknownTags Tags

+ func NewOffsetForLeaderEpochResponseTopicPartition() OffsetForLeaderEpochResponseTopicPartition

+ func (v *OffsetForLeaderEpochResponseTopicPartition) Default()

+ type ProduceRequest struct

+ Acks int16

+ TimeoutMillis int32

+ Topics []ProduceRequestTopic

+ TransactionID *string

+ UnknownTags Tags

+ Version int16

+ func NewProduceRequest() ProduceRequest

+ func NewPtrProduceRequest() *ProduceRequest

+ func (*ProduceRequest) Key() int16

+ func (*ProduceRequest) MaxVersion() int16

+ func (v *ProduceRequest) AppendTo(dst []byte) []byte

+ func (v *ProduceRequest) Default()

+ func (v *ProduceRequest) GetVersion() int16

+ func (v *ProduceRequest) IsFlexible() bool

+ func (v *ProduceRequest) ReadFrom(src []byte) error

+ func (v *ProduceRequest) RequestWith(ctx context.Context, r Requestor) (*ProduceResponse, error)

+ func (v *ProduceRequest) ResponseKind() Response

+ func (v *ProduceRequest) SetVersion(version int16)

+ func (v *ProduceRequest) Timeout() int32

+ type ProduceRequestTopic struct

+ Partitions []ProduceRequestTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewProduceRequestTopic() ProduceRequestTopic

+ func (v *ProduceRequestTopic) Default()

+ type ProduceRequestTopicPartition struct

+ Partition int32

+ Records []byte

+ UnknownTags Tags

+ func NewProduceRequestTopicPartition() ProduceRequestTopicPartition

+ func (v *ProduceRequestTopicPartition) Default()

+ type ProduceResponse struct

+ ThrottleMillis int32

+ Topics []ProduceResponseTopic

+ UnknownTags Tags

+ Version int16

+ func NewProduceResponse() ProduceResponse

+ func NewPtrProduceResponse() *ProduceResponse

+ func (*ProduceResponse) Key() int16

+ func (*ProduceResponse) MaxVersion() int16

+ func (v *ProduceResponse) AppendTo(dst []byte) []byte

+ func (v *ProduceResponse) Default()

+ func (v *ProduceResponse) GetVersion() int16

+ func (v *ProduceResponse) IsFlexible() bool

+ func (v *ProduceResponse) ReadFrom(src []byte) error

+ func (v *ProduceResponse) RequestKind() Request

+ func (v *ProduceResponse) SetVersion(version int16)

+ func (v *ProduceResponse) Throttle() (int32, bool)

+ type ProduceResponseTopic struct

+ Partitions []ProduceResponseTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewProduceResponseTopic() ProduceResponseTopic

+ func (v *ProduceResponseTopic) Default()

+ type ProduceResponseTopicPartition struct

+ BaseOffset int64

+ ErrorCode int16

+ ErrorMessage *string

+ ErrorRecords []ProduceResponseTopicPartitionErrorRecord

+ LogAppendTime int64

+ LogStartOffset int64

+ Partition int32

+ UnknownTags Tags

+ func NewProduceResponseTopicPartition() ProduceResponseTopicPartition

+ func (v *ProduceResponseTopicPartition) Default()

+ type ProduceResponseTopicPartitionErrorRecord struct

+ ErrorMessage *string

+ RelativeOffset int32

+ UnknownTags Tags

+ func NewProduceResponseTopicPartitionErrorRecord() ProduceResponseTopicPartitionErrorRecord

+ func (v *ProduceResponseTopicPartitionErrorRecord) Default()

+ type QuotasMatchType int8

+ const QuotasMatchTypeAny

+ const QuotasMatchTypeDefault

+ const QuotasMatchTypeExact

+ func ParseQuotasMatchType(s string) (QuotasMatchType, error)

+ func (e *QuotasMatchType) UnmarshalText(text []byte) error

+ func (e QuotasMatchType) MarshalText() (text []byte, err error)

+ func (v QuotasMatchType) String() string

+ type Record struct

+ Attributes int8

+ Headers []Header

+ Key []byte

+ Length int32

+ OffsetDelta int32

+ TimestampDelta int32

+ Value []byte

+ func NewRecord() Record

+ func (v *Record) AppendTo(dst []byte) []byte

+ func (v *Record) Default()

+ func (v *Record) ReadFrom(src []byte) error

+ type RecordBatch struct

+ Attributes int16

+ CRC int32

+ FirstOffset int64

+ FirstSequence int32

+ FirstTimestamp int64

+ LastOffsetDelta int32

+ Length int32

+ Magic int8

+ MaxTimestamp int64

+ NumRecords int32

+ PartitionLeaderEpoch int32

+ ProducerEpoch int16

+ ProducerID int64

+ Records []byte

+ func NewRecordBatch() RecordBatch

+ func (v *RecordBatch) AppendTo(dst []byte) []byte

+ func (v *RecordBatch) Default()

+ func (v *RecordBatch) ReadFrom(src []byte) error

+ type RenewDelegationTokenRequest struct

+ HMAC []byte

+ RenewTimeMillis int64

+ UnknownTags Tags

+ Version int16

+ func NewPtrRenewDelegationTokenRequest() *RenewDelegationTokenRequest

+ func NewRenewDelegationTokenRequest() RenewDelegationTokenRequest

+ func (*RenewDelegationTokenRequest) Key() int16

+ func (*RenewDelegationTokenRequest) MaxVersion() int16

+ func (v *RenewDelegationTokenRequest) AppendTo(dst []byte) []byte

+ func (v *RenewDelegationTokenRequest) Default()

+ func (v *RenewDelegationTokenRequest) GetVersion() int16

+ func (v *RenewDelegationTokenRequest) IsFlexible() bool

+ func (v *RenewDelegationTokenRequest) ReadFrom(src []byte) error

+ func (v *RenewDelegationTokenRequest) RequestWith(ctx context.Context, r Requestor) (*RenewDelegationTokenResponse, error)

+ func (v *RenewDelegationTokenRequest) ResponseKind() Response

+ func (v *RenewDelegationTokenRequest) SetVersion(version int16)

+ type RenewDelegationTokenResponse struct

+ ErrorCode int16

+ ExpiryTimestamp int64

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewPtrRenewDelegationTokenResponse() *RenewDelegationTokenResponse

+ func NewRenewDelegationTokenResponse() RenewDelegationTokenResponse

+ func (*RenewDelegationTokenResponse) Key() int16

+ func (*RenewDelegationTokenResponse) MaxVersion() int16

+ func (v *RenewDelegationTokenResponse) AppendTo(dst []byte) []byte

+ func (v *RenewDelegationTokenResponse) Default()

+ func (v *RenewDelegationTokenResponse) GetVersion() int16

+ func (v *RenewDelegationTokenResponse) IsFlexible() bool

+ func (v *RenewDelegationTokenResponse) ReadFrom(src []byte) error

+ func (v *RenewDelegationTokenResponse) RequestKind() Request

+ func (v *RenewDelegationTokenResponse) SetVersion(version int16)

+ func (v *RenewDelegationTokenResponse) Throttle() (int32, bool)

+ type Request interface

+ AppendTo func([]byte) []byte

+ GetVersion func() int16

+ IsFlexible func() bool

+ Key func() int16

+ MaxVersion func() int16

+ ReadFrom func([]byte) error

+ ResponseKind func() Response

+ SetVersion func(int16)

+ func RequestForKey(key int16) Request

+ type RequestFormatter struct

+ func NewRequestFormatter(opts ...RequestFormatterOpt) *RequestFormatter

+ func (f *RequestFormatter) AppendRequest(dst []byte, r Request, correlationID int32) []byte

+ type RequestFormatterOpt interface

+ func FormatterClientID(id string) RequestFormatterOpt

+ type Requestor interface

+ Request func(context.Context, Request) (Response, error)

+ type Response interface

+ AppendTo func([]byte) []byte

+ GetVersion func() int16

+ IsFlexible func() bool

+ Key func() int16

+ MaxVersion func() int16

+ ReadFrom func([]byte) error

+ RequestKind func() Request

+ SetVersion func(int16)

+ func ResponseForKey(key int16) Response

+ type SASLAuthenticateRequest struct

+ SASLAuthBytes []byte

+ UnknownTags Tags

+ Version int16

+ func NewPtrSASLAuthenticateRequest() *SASLAuthenticateRequest

+ func NewSASLAuthenticateRequest() SASLAuthenticateRequest

+ func (*SASLAuthenticateRequest) Key() int16

+ func (*SASLAuthenticateRequest) MaxVersion() int16

+ func (v *SASLAuthenticateRequest) AppendTo(dst []byte) []byte

+ func (v *SASLAuthenticateRequest) Default()

+ func (v *SASLAuthenticateRequest) GetVersion() int16

+ func (v *SASLAuthenticateRequest) IsFlexible() bool

+ func (v *SASLAuthenticateRequest) ReadFrom(src []byte) error

+ func (v *SASLAuthenticateRequest) RequestWith(ctx context.Context, r Requestor) (*SASLAuthenticateResponse, error)

+ func (v *SASLAuthenticateRequest) ResponseKind() Response

+ func (v *SASLAuthenticateRequest) SetVersion(version int16)

+ type SASLAuthenticateResponse struct

+ ErrorCode int16

+ ErrorMessage *string

+ SASLAuthBytes []byte

+ SessionLifetimeMillis int64

+ UnknownTags Tags

+ Version int16

+ func NewPtrSASLAuthenticateResponse() *SASLAuthenticateResponse

+ func NewSASLAuthenticateResponse() SASLAuthenticateResponse

+ func (*SASLAuthenticateResponse) Key() int16

+ func (*SASLAuthenticateResponse) MaxVersion() int16

+ func (v *SASLAuthenticateResponse) AppendTo(dst []byte) []byte

+ func (v *SASLAuthenticateResponse) Default()

+ func (v *SASLAuthenticateResponse) GetVersion() int16

+ func (v *SASLAuthenticateResponse) IsFlexible() bool

+ func (v *SASLAuthenticateResponse) ReadFrom(src []byte) error

+ func (v *SASLAuthenticateResponse) RequestKind() Request

+ func (v *SASLAuthenticateResponse) SetVersion(version int16)

+ type SASLHandshakeRequest struct

+ Mechanism string

+ Version int16

+ func NewPtrSASLHandshakeRequest() *SASLHandshakeRequest

+ func NewSASLHandshakeRequest() SASLHandshakeRequest

+ func (*SASLHandshakeRequest) Key() int16

+ func (*SASLHandshakeRequest) MaxVersion() int16

+ func (v *SASLHandshakeRequest) AppendTo(dst []byte) []byte

+ func (v *SASLHandshakeRequest) Default()

+ func (v *SASLHandshakeRequest) GetVersion() int16

+ func (v *SASLHandshakeRequest) IsFlexible() bool

+ func (v *SASLHandshakeRequest) ReadFrom(src []byte) error

+ func (v *SASLHandshakeRequest) RequestWith(ctx context.Context, r Requestor) (*SASLHandshakeResponse, error)

+ func (v *SASLHandshakeRequest) ResponseKind() Response

+ func (v *SASLHandshakeRequest) SetVersion(version int16)

+ type SASLHandshakeResponse struct

+ ErrorCode int16

+ SupportedMechanisms []string

+ Version int16

+ func NewPtrSASLHandshakeResponse() *SASLHandshakeResponse

+ func NewSASLHandshakeResponse() SASLHandshakeResponse

+ func (*SASLHandshakeResponse) Key() int16

+ func (*SASLHandshakeResponse) MaxVersion() int16

+ func (v *SASLHandshakeResponse) AppendTo(dst []byte) []byte

+ func (v *SASLHandshakeResponse) Default()

+ func (v *SASLHandshakeResponse) GetVersion() int16

+ func (v *SASLHandshakeResponse) IsFlexible() bool

+ func (v *SASLHandshakeResponse) ReadFrom(src []byte) error

+ func (v *SASLHandshakeResponse) RequestKind() Request

+ func (v *SASLHandshakeResponse) SetVersion(version int16)

+ type StickyMemberMetadata struct

+ CurrentAssignment []StickyMemberMetadataCurrentAssignment

+ Generation int32

+ func NewStickyMemberMetadata() StickyMemberMetadata

+ func (s *StickyMemberMetadata) AppendTo(dst []byte) []byte

+ func (s *StickyMemberMetadata) ReadFrom(src []byte) error

+ func (v *StickyMemberMetadata) Default()

+ type StickyMemberMetadataCurrentAssignment struct

+ Partitions []int32

+ Topic string

+ func NewStickyMemberMetadataCurrentAssignment() StickyMemberMetadataCurrentAssignment

+ func (v *StickyMemberMetadataCurrentAssignment) Default()

+ type StopReplicaRequest struct

+ BrokerEpoch int64

+ ControllerEpoch int32

+ ControllerID int32

+ DeletePartitions bool

+ Topics []StopReplicaRequestTopic

+ UnknownTags Tags

+ Version int16

+ func NewPtrStopReplicaRequest() *StopReplicaRequest

+ func NewStopReplicaRequest() StopReplicaRequest

+ func (*StopReplicaRequest) Key() int16

+ func (*StopReplicaRequest) MaxVersion() int16

+ func (v *StopReplicaRequest) AppendTo(dst []byte) []byte

+ func (v *StopReplicaRequest) Default()

+ func (v *StopReplicaRequest) GetVersion() int16

+ func (v *StopReplicaRequest) IsFlexible() bool

+ func (v *StopReplicaRequest) ReadFrom(src []byte) error

+ func (v *StopReplicaRequest) RequestWith(ctx context.Context, r Requestor) (*StopReplicaResponse, error)

+ func (v *StopReplicaRequest) ResponseKind() Response

+ func (v *StopReplicaRequest) SetVersion(version int16)

+ type StopReplicaRequestTopic struct

+ Partition int32

+ PartitionStates []StopReplicaRequestTopicPartitionState

+ Partitions []int32

+ Topic string

+ UnknownTags Tags

+ func NewStopReplicaRequestTopic() StopReplicaRequestTopic

+ func (v *StopReplicaRequestTopic) Default()

+ type StopReplicaRequestTopicPartitionState struct

+ Delete bool

+ LeaderEpoch int32

+ Partition int32

+ UnknownTags Tags

+ func NewStopReplicaRequestTopicPartitionState() StopReplicaRequestTopicPartitionState

+ func (v *StopReplicaRequestTopicPartitionState) Default()

+ type StopReplicaResponse struct

+ ErrorCode int16

+ Partitions []StopReplicaResponsePartition

+ UnknownTags Tags

+ Version int16

+ func NewPtrStopReplicaResponse() *StopReplicaResponse

+ func NewStopReplicaResponse() StopReplicaResponse

+ func (*StopReplicaResponse) Key() int16

+ func (*StopReplicaResponse) MaxVersion() int16

+ func (v *StopReplicaResponse) AppendTo(dst []byte) []byte

+ func (v *StopReplicaResponse) Default()

+ func (v *StopReplicaResponse) GetVersion() int16

+ func (v *StopReplicaResponse) IsFlexible() bool

+ func (v *StopReplicaResponse) ReadFrom(src []byte) error

+ func (v *StopReplicaResponse) RequestKind() Request

+ func (v *StopReplicaResponse) SetVersion(version int16)

+ type StopReplicaResponsePartition struct

+ ErrorCode int16

+ Partition int32

+ Topic string

+ UnknownTags Tags

+ func NewStopReplicaResponsePartition() StopReplicaResponsePartition

+ func (v *StopReplicaResponsePartition) Default()

+ type SyncGroupRequest struct

+ Generation int32

+ Group string

+ GroupAssignment []SyncGroupRequestGroupAssignment

+ InstanceID *string

+ MemberID string

+ Protocol *string

+ ProtocolType *string

+ UnknownTags Tags

+ Version int16

+ func NewPtrSyncGroupRequest() *SyncGroupRequest

+ func NewSyncGroupRequest() SyncGroupRequest

+ func (*SyncGroupRequest) Key() int16

+ func (*SyncGroupRequest) MaxVersion() int16

+ func (v *SyncGroupRequest) AppendTo(dst []byte) []byte

+ func (v *SyncGroupRequest) Default()

+ func (v *SyncGroupRequest) GetVersion() int16

+ func (v *SyncGroupRequest) IsFlexible() bool

+ func (v *SyncGroupRequest) IsGroupCoordinatorRequest()

+ func (v *SyncGroupRequest) ReadFrom(src []byte) error

+ func (v *SyncGroupRequest) RequestWith(ctx context.Context, r Requestor) (*SyncGroupResponse, error)

+ func (v *SyncGroupRequest) ResponseKind() Response

+ func (v *SyncGroupRequest) SetVersion(version int16)

+ type SyncGroupRequestGroupAssignment struct

+ MemberAssignment []byte

+ MemberID string

+ UnknownTags Tags

+ func NewSyncGroupRequestGroupAssignment() SyncGroupRequestGroupAssignment

+ func (v *SyncGroupRequestGroupAssignment) Default()

+ type SyncGroupResponse struct

+ ErrorCode int16

+ MemberAssignment []byte

+ Protocol *string

+ ProtocolType *string

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewPtrSyncGroupResponse() *SyncGroupResponse

+ func NewSyncGroupResponse() SyncGroupResponse

+ func (*SyncGroupResponse) Key() int16

+ func (*SyncGroupResponse) MaxVersion() int16

+ func (v *SyncGroupResponse) AppendTo(dst []byte) []byte

+ func (v *SyncGroupResponse) Default()

+ func (v *SyncGroupResponse) GetVersion() int16

+ func (v *SyncGroupResponse) IsFlexible() bool

+ func (v *SyncGroupResponse) ReadFrom(src []byte) error

+ func (v *SyncGroupResponse) RequestKind() Request

+ func (v *SyncGroupResponse) SetVersion(version int16)

+ func (v *SyncGroupResponse) Throttle() (int32, bool)

+ type TagReader interface

+ Span func(n int) []byte

+ Uvarint func() uint32

+ type Tags struct

+ func ReadTags(b TagReader) Tags

+ func (t *Tags) AppendEach(dst []byte) []byte

+ func (t *Tags) Each(fn func(uint32, []byte))

+ func (t *Tags) Len() int

+ func (t *Tags) Set(key uint32, val []byte)

+ type ThrottleResponse interface

+ Throttle func() (int32, bool)

+ type TimeoutRequest interface

+ Timeout func() int32

+ type TransactionState int8

+ const TransactionStateCompleteAbort

+ const TransactionStateCompleteCommit

+ const TransactionStateDead

+ const TransactionStateEmpty

+ const TransactionStateOngoing

+ const TransactionStatePrepareAbort

+ const TransactionStatePrepareCommit

+ const TransactionStatePrepareEpochFence

+ func ParseTransactionState(s string) (TransactionState, error)

+ func (e *TransactionState) UnmarshalText(text []byte) error

+ func (e TransactionState) MarshalText() (text []byte, err error)

+ func (v TransactionState) String() string

+ type TxnCoordinatorRequest interface

+ IsTxnCoordinatorRequest func()

+ type TxnMetadataKey struct

+ TransactionalID string

+ Version int16

+ func NewTxnMetadataKey() TxnMetadataKey

+ func (v *TxnMetadataKey) AppendTo(dst []byte) []byte

+ func (v *TxnMetadataKey) Default()

+ func (v *TxnMetadataKey) ReadFrom(src []byte) error

+ type TxnMetadataValue struct

+ LastUpdateTimestamp int64

+ ProducerEpoch int16

+ ProducerID int64

+ StartTimestamp int64

+ State TransactionState

+ TimeoutMillis int32

+ Topics []TxnMetadataValueTopic

+ Version int16

+ func NewTxnMetadataValue() TxnMetadataValue

+ func (v *TxnMetadataValue) AppendTo(dst []byte) []byte

+ func (v *TxnMetadataValue) Default()

+ func (v *TxnMetadataValue) ReadFrom(src []byte) error

+ type TxnMetadataValueTopic struct

+ Partitions []int32

+ Topic string

+ func NewTxnMetadataValueTopic() TxnMetadataValueTopic

+ func (v *TxnMetadataValueTopic) Default()

+ type TxnOffsetCommitRequest struct

+ Generation int32

+ Group string

+ InstanceID *string

+ MemberID string

+ ProducerEpoch int16

+ ProducerID int64

+ Topics []TxnOffsetCommitRequestTopic

+ TransactionalID string

+ UnknownTags Tags

+ Version int16

+ func NewPtrTxnOffsetCommitRequest() *TxnOffsetCommitRequest

+ func NewTxnOffsetCommitRequest() TxnOffsetCommitRequest

+ func (*TxnOffsetCommitRequest) Key() int16

+ func (*TxnOffsetCommitRequest) MaxVersion() int16

+ func (v *TxnOffsetCommitRequest) AppendTo(dst []byte) []byte

+ func (v *TxnOffsetCommitRequest) Default()

+ func (v *TxnOffsetCommitRequest) GetVersion() int16

+ func (v *TxnOffsetCommitRequest) IsFlexible() bool

+ func (v *TxnOffsetCommitRequest) IsGroupCoordinatorRequest()

+ func (v *TxnOffsetCommitRequest) ReadFrom(src []byte) error

+ func (v *TxnOffsetCommitRequest) RequestWith(ctx context.Context, r Requestor) (*TxnOffsetCommitResponse, error)

+ func (v *TxnOffsetCommitRequest) ResponseKind() Response

+ func (v *TxnOffsetCommitRequest) SetVersion(version int16)

+ type TxnOffsetCommitRequestTopic struct

+ Partitions []TxnOffsetCommitRequestTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewTxnOffsetCommitRequestTopic() TxnOffsetCommitRequestTopic

+ func (v *TxnOffsetCommitRequestTopic) Default()

+ type TxnOffsetCommitRequestTopicPartition struct

+ LeaderEpoch int32

+ Metadata *string

+ Offset int64

+ Partition int32

+ UnknownTags Tags

+ func NewTxnOffsetCommitRequestTopicPartition() TxnOffsetCommitRequestTopicPartition

+ func (v *TxnOffsetCommitRequestTopicPartition) Default()

+ type TxnOffsetCommitResponse struct

+ ThrottleMillis int32

+ Topics []TxnOffsetCommitResponseTopic

+ UnknownTags Tags

+ Version int16

+ func NewPtrTxnOffsetCommitResponse() *TxnOffsetCommitResponse

+ func NewTxnOffsetCommitResponse() TxnOffsetCommitResponse

+ func (*TxnOffsetCommitResponse) Key() int16

+ func (*TxnOffsetCommitResponse) MaxVersion() int16

+ func (v *TxnOffsetCommitResponse) AppendTo(dst []byte) []byte

+ func (v *TxnOffsetCommitResponse) Default()

+ func (v *TxnOffsetCommitResponse) GetVersion() int16

+ func (v *TxnOffsetCommitResponse) IsFlexible() bool

+ func (v *TxnOffsetCommitResponse) ReadFrom(src []byte) error

+ func (v *TxnOffsetCommitResponse) RequestKind() Request

+ func (v *TxnOffsetCommitResponse) SetVersion(version int16)

+ func (v *TxnOffsetCommitResponse) Throttle() (int32, bool)

+ type TxnOffsetCommitResponseTopic struct

+ Partitions []TxnOffsetCommitResponseTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewTxnOffsetCommitResponseTopic() TxnOffsetCommitResponseTopic

+ func (v *TxnOffsetCommitResponseTopic) Default()

+ type TxnOffsetCommitResponseTopicPartition struct

+ ErrorCode int16

+ Partition int32

+ UnknownTags Tags

+ func NewTxnOffsetCommitResponseTopicPartition() TxnOffsetCommitResponseTopicPartition

+ func (v *TxnOffsetCommitResponseTopicPartition) Default()

+ type UnregisterBrokerRequest struct

+ BrokerID int32

+ UnknownTags Tags

+ Version int16

+ func NewPtrUnregisterBrokerRequest() *UnregisterBrokerRequest

+ func NewUnregisterBrokerRequest() UnregisterBrokerRequest

+ func (*UnregisterBrokerRequest) Key() int16

+ func (*UnregisterBrokerRequest) MaxVersion() int16

+ func (v *UnregisterBrokerRequest) AppendTo(dst []byte) []byte

+ func (v *UnregisterBrokerRequest) Default()

+ func (v *UnregisterBrokerRequest) GetVersion() int16

+ func (v *UnregisterBrokerRequest) IsFlexible() bool

+ func (v *UnregisterBrokerRequest) ReadFrom(src []byte) error

+ func (v *UnregisterBrokerRequest) RequestWith(ctx context.Context, r Requestor) (*UnregisterBrokerResponse, error)

+ func (v *UnregisterBrokerRequest) ResponseKind() Response

+ func (v *UnregisterBrokerRequest) SetVersion(version int16)

+ type UnregisterBrokerResponse struct

+ ErrorCode int16

+ ErrorMessage *string

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewPtrUnregisterBrokerResponse() *UnregisterBrokerResponse

+ func NewUnregisterBrokerResponse() UnregisterBrokerResponse

+ func (*UnregisterBrokerResponse) Key() int16

+ func (*UnregisterBrokerResponse) MaxVersion() int16

+ func (v *UnregisterBrokerResponse) AppendTo(dst []byte) []byte

+ func (v *UnregisterBrokerResponse) Default()

+ func (v *UnregisterBrokerResponse) GetVersion() int16

+ func (v *UnregisterBrokerResponse) IsFlexible() bool

+ func (v *UnregisterBrokerResponse) ReadFrom(src []byte) error

+ func (v *UnregisterBrokerResponse) RequestKind() Request

+ func (v *UnregisterBrokerResponse) SetVersion(version int16)

+ func (v *UnregisterBrokerResponse) Throttle() (int32, bool)

+ type UpdateFeaturesRequest struct

+ FeatureUpdates []UpdateFeaturesRequestFeatureUpdate

+ TimeoutMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewPtrUpdateFeaturesRequest() *UpdateFeaturesRequest

+ func NewUpdateFeaturesRequest() UpdateFeaturesRequest

+ func (*UpdateFeaturesRequest) Key() int16

+ func (*UpdateFeaturesRequest) MaxVersion() int16

+ func (v *UpdateFeaturesRequest) AppendTo(dst []byte) []byte

+ func (v *UpdateFeaturesRequest) Default()

+ func (v *UpdateFeaturesRequest) GetVersion() int16

+ func (v *UpdateFeaturesRequest) IsAdminRequest()

+ func (v *UpdateFeaturesRequest) IsFlexible() bool

+ func (v *UpdateFeaturesRequest) ReadFrom(src []byte) error

+ func (v *UpdateFeaturesRequest) RequestWith(ctx context.Context, r Requestor) (*UpdateFeaturesResponse, error)

+ func (v *UpdateFeaturesRequest) ResponseKind() Response

+ func (v *UpdateFeaturesRequest) SetVersion(version int16)

+ func (v *UpdateFeaturesRequest) Timeout() int32

+ type UpdateFeaturesRequestFeatureUpdate struct

+ AllowDowngrade bool

+ Feature string

+ MaxVersionLevel int16

+ UnknownTags Tags

+ func NewUpdateFeaturesRequestFeatureUpdate() UpdateFeaturesRequestFeatureUpdate

+ func (v *UpdateFeaturesRequestFeatureUpdate) Default()

+ type UpdateFeaturesResponse struct

+ ErrorCode int16

+ ErrorMessage *string

+ Results []UpdateFeaturesResponseResult

+ ThrottleMillis int32

+ UnknownTags Tags

+ Version int16

+ func NewPtrUpdateFeaturesResponse() *UpdateFeaturesResponse

+ func NewUpdateFeaturesResponse() UpdateFeaturesResponse

+ func (*UpdateFeaturesResponse) Key() int16

+ func (*UpdateFeaturesResponse) MaxVersion() int16

+ func (v *UpdateFeaturesResponse) AppendTo(dst []byte) []byte

+ func (v *UpdateFeaturesResponse) Default()

+ func (v *UpdateFeaturesResponse) GetVersion() int16

+ func (v *UpdateFeaturesResponse) IsFlexible() bool

+ func (v *UpdateFeaturesResponse) ReadFrom(src []byte) error

+ func (v *UpdateFeaturesResponse) RequestKind() Request

+ func (v *UpdateFeaturesResponse) SetVersion(version int16)

+ func (v *UpdateFeaturesResponse) Throttle() (int32, bool)

+ type UpdateFeaturesResponseResult struct

+ ErrorCode int16

+ ErrorMessage *string

+ Feature string

+ UnknownTags Tags

+ func NewUpdateFeaturesResponseResult() UpdateFeaturesResponseResult

+ func (v *UpdateFeaturesResponseResult) Default()

+ type UpdateMetadataRequest struct

+ BrokerEpoch int64

+ ControllerEpoch int32

+ ControllerID int32

+ LiveBrokers []UpdateMetadataRequestLiveBroker

+ PartitionStates []UpdateMetadataRequestTopicPartition

+ TopicStates []UpdateMetadataRequestTopicState

+ UnknownTags Tags

+ Version int16

+ func NewPtrUpdateMetadataRequest() *UpdateMetadataRequest

+ func NewUpdateMetadataRequest() UpdateMetadataRequest

+ func (*UpdateMetadataRequest) Key() int16

+ func (*UpdateMetadataRequest) MaxVersion() int16

+ func (v *UpdateMetadataRequest) AppendTo(dst []byte) []byte

+ func (v *UpdateMetadataRequest) Default()

+ func (v *UpdateMetadataRequest) GetVersion() int16

+ func (v *UpdateMetadataRequest) IsFlexible() bool

+ func (v *UpdateMetadataRequest) ReadFrom(src []byte) error

+ func (v *UpdateMetadataRequest) RequestWith(ctx context.Context, r Requestor) (*UpdateMetadataResponse, error)

+ func (v *UpdateMetadataRequest) ResponseKind() Response

+ func (v *UpdateMetadataRequest) SetVersion(version int16)

+ type UpdateMetadataRequestLiveBroker struct

+ Endpoints []UpdateMetadataRequestLiveBrokerEndpoint

+ Host string

+ ID int32

+ Port int32

+ Rack *string

+ UnknownTags Tags

+ func NewUpdateMetadataRequestLiveBroker() UpdateMetadataRequestLiveBroker

+ func (v *UpdateMetadataRequestLiveBroker) Default()

+ type UpdateMetadataRequestLiveBrokerEndpoint struct

+ Host string

+ ListenerName string

+ Port int32

+ SecurityProtocol int16

+ UnknownTags Tags

+ func NewUpdateMetadataRequestLiveBrokerEndpoint() UpdateMetadataRequestLiveBrokerEndpoint

+ func (v *UpdateMetadataRequestLiveBrokerEndpoint) Default()

+ type UpdateMetadataRequestTopicPartition struct

+ ControllerEpoch int32

+ ISR []int32

+ Leader int32

+ LeaderEpoch int32

+ OfflineReplicas []int32

+ Partition int32

+ Replicas []int32

+ Topic string

+ UnknownTags Tags

+ ZKVersion int32

+ func NewUpdateMetadataRequestTopicPartition() UpdateMetadataRequestTopicPartition

+ func (v *UpdateMetadataRequestTopicPartition) Default()

+ type UpdateMetadataRequestTopicState struct

+ PartitionStates []UpdateMetadataRequestTopicPartition

+ Topic string

+ TopicID [16]byte

+ UnknownTags Tags

+ func NewUpdateMetadataRequestTopicState() UpdateMetadataRequestTopicState

+ func (v *UpdateMetadataRequestTopicState) Default()

+ type UpdateMetadataResponse struct

+ ErrorCode int16

+ UnknownTags Tags

+ Version int16

+ func NewPtrUpdateMetadataResponse() *UpdateMetadataResponse

+ func NewUpdateMetadataResponse() UpdateMetadataResponse

+ func (*UpdateMetadataResponse) Key() int16

+ func (*UpdateMetadataResponse) MaxVersion() int16

+ func (v *UpdateMetadataResponse) AppendTo(dst []byte) []byte

+ func (v *UpdateMetadataResponse) Default()

+ func (v *UpdateMetadataResponse) GetVersion() int16

+ func (v *UpdateMetadataResponse) IsFlexible() bool

+ func (v *UpdateMetadataResponse) ReadFrom(src []byte) error

+ func (v *UpdateMetadataResponse) RequestKind() Request

+ func (v *UpdateMetadataResponse) SetVersion(version int16)

+ type VoteRequest struct

+ ClusterID *string

+ Topics []VoteRequestTopic

+ UnknownTags Tags

+ Version int16

+ func NewPtrVoteRequest() *VoteRequest

+ func NewVoteRequest() VoteRequest

+ func (*VoteRequest) Key() int16

+ func (*VoteRequest) MaxVersion() int16

+ func (v *VoteRequest) AppendTo(dst []byte) []byte

+ func (v *VoteRequest) Default()

+ func (v *VoteRequest) GetVersion() int16

+ func (v *VoteRequest) IsAdminRequest()

+ func (v *VoteRequest) IsFlexible() bool

+ func (v *VoteRequest) ReadFrom(src []byte) error

+ func (v *VoteRequest) RequestWith(ctx context.Context, r Requestor) (*VoteResponse, error)

+ func (v *VoteRequest) ResponseKind() Response

+ func (v *VoteRequest) SetVersion(version int16)

+ type VoteRequestTopic struct

+ Partitions []VoteRequestTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewVoteRequestTopic() VoteRequestTopic

+ func (v *VoteRequestTopic) Default()

+ type VoteRequestTopicPartition struct

+ CandidateEpoch int32

+ CandidateID int32

+ LastOffset int64

+ LastOffsetEpoch int32

+ Partition int32

+ UnknownTags Tags

+ func NewVoteRequestTopicPartition() VoteRequestTopicPartition

+ func (v *VoteRequestTopicPartition) Default()

+ type VoteResponse struct

+ ErrorCode int16

+ Topics []VoteResponseTopic

+ UnknownTags Tags

+ Version int16

+ func NewPtrVoteResponse() *VoteResponse

+ func NewVoteResponse() VoteResponse

+ func (*VoteResponse) Key() int16

+ func (*VoteResponse) MaxVersion() int16

+ func (v *VoteResponse) AppendTo(dst []byte) []byte

+ func (v *VoteResponse) Default()

+ func (v *VoteResponse) GetVersion() int16

+ func (v *VoteResponse) IsFlexible() bool

+ func (v *VoteResponse) ReadFrom(src []byte) error

+ func (v *VoteResponse) RequestKind() Request

+ func (v *VoteResponse) SetVersion(version int16)

+ type VoteResponseTopic struct

+ Partitions []VoteResponseTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewVoteResponseTopic() VoteResponseTopic

+ func (v *VoteResponseTopic) Default()

+ type VoteResponseTopicPartition struct

+ ErrorCode int16

+ LeaderID int32

+ Partition int32

+ UnknownTags Tags

+ VoteGranted bool

+ func NewVoteResponseTopicPartition() VoteResponseTopicPartition

+ func (v *VoteResponseTopicPartition) Default()

+ type WriteTxnMarkersRequest struct

+ Markers []WriteTxnMarkersRequestMarker

+ UnknownTags Tags

+ Version int16

+ func NewPtrWriteTxnMarkersRequest() *WriteTxnMarkersRequest

+ func NewWriteTxnMarkersRequest() WriteTxnMarkersRequest

+ func (*WriteTxnMarkersRequest) Key() int16

+ func (*WriteTxnMarkersRequest) MaxVersion() int16

+ func (v *WriteTxnMarkersRequest) AppendTo(dst []byte) []byte

+ func (v *WriteTxnMarkersRequest) Default()

+ func (v *WriteTxnMarkersRequest) GetVersion() int16

+ func (v *WriteTxnMarkersRequest) IsFlexible() bool

+ func (v *WriteTxnMarkersRequest) ReadFrom(src []byte) error

+ func (v *WriteTxnMarkersRequest) RequestWith(ctx context.Context, r Requestor) (*WriteTxnMarkersResponse, error)

+ func (v *WriteTxnMarkersRequest) ResponseKind() Response

+ func (v *WriteTxnMarkersRequest) SetVersion(version int16)

+ type WriteTxnMarkersRequestMarker struct

+ Committed bool

+ CoordinatorEpoch int32

+ ProducerEpoch int16

+ ProducerID int64

+ Topics []WriteTxnMarkersRequestMarkerTopic

+ UnknownTags Tags

+ func NewWriteTxnMarkersRequestMarker() WriteTxnMarkersRequestMarker

+ func (v *WriteTxnMarkersRequestMarker) Default()

+ type WriteTxnMarkersRequestMarkerTopic struct

+ Partitions []int32

+ Topic string

+ UnknownTags Tags

+ func NewWriteTxnMarkersRequestMarkerTopic() WriteTxnMarkersRequestMarkerTopic

+ func (v *WriteTxnMarkersRequestMarkerTopic) Default()

+ type WriteTxnMarkersResponse struct

+ Markers []WriteTxnMarkersResponseMarker

+ UnknownTags Tags

+ Version int16

+ func NewPtrWriteTxnMarkersResponse() *WriteTxnMarkersResponse

+ func NewWriteTxnMarkersResponse() WriteTxnMarkersResponse

+ func (*WriteTxnMarkersResponse) Key() int16

+ func (*WriteTxnMarkersResponse) MaxVersion() int16

+ func (v *WriteTxnMarkersResponse) AppendTo(dst []byte) []byte

+ func (v *WriteTxnMarkersResponse) Default()

+ func (v *WriteTxnMarkersResponse) GetVersion() int16

+ func (v *WriteTxnMarkersResponse) IsFlexible() bool

+ func (v *WriteTxnMarkersResponse) ReadFrom(src []byte) error

+ func (v *WriteTxnMarkersResponse) RequestKind() Request

+ func (v *WriteTxnMarkersResponse) SetVersion(version int16)

+ type WriteTxnMarkersResponseMarker struct

+ ProducerID int64

+ Topics []WriteTxnMarkersResponseMarkerTopic

+ UnknownTags Tags

+ func NewWriteTxnMarkersResponseMarker() WriteTxnMarkersResponseMarker

+ func (v *WriteTxnMarkersResponseMarker) Default()

+ type WriteTxnMarkersResponseMarkerTopic struct

+ Partitions []WriteTxnMarkersResponseMarkerTopicPartition

+ Topic string

+ UnknownTags Tags

+ func NewWriteTxnMarkersResponseMarkerTopic() WriteTxnMarkersResponseMarkerTopic

+ func (v *WriteTxnMarkersResponseMarkerTopic) Default()

+ type WriteTxnMarkersResponseMarkerTopicPartition struct

+ ErrorCode int16

+ Partition int32

+ UnknownTags Tags

+ func NewWriteTxnMarkersResponseMarkerTopicPartition() WriteTxnMarkersResponseMarkerTopicPartition

+ func (v *WriteTxnMarkersResponseMarkerTopicPartition) Default()

Other modules containing this package

github.com/twmb/franz-go

github.com/twmb/franz-go/pkg/kmsg/v2

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL