| $sel:acks:Request | Kafka.Produce.Request.V9 |
| $sel:allowAutoTopicCreation:Request | Kafka.Metadata.Request.V12 |
| $sel:apiKey:ApiKeyVersionSupport | Kafka.ApiVersions.Response.V3 |
| $sel:apiKey:Header | Kafka.Message.Request.V2 |
| $sel:apiKeys:Response | Kafka.ApiVersions.Response.V3 |
| $sel:apiVersion:Header | Kafka.Message.Request.V2 |
| $sel:assignedPartitions:Assignment | Kafka.Assignment.Request.V1, Kafka.Assignment.Response.V1 |
| $sel:assignment:Assignment | Kafka.SyncGroup.Request.V5 |
| $sel:assignment:Response | Kafka.SyncGroup.Response.V5 |
| $sel:assignments:Request | Kafka.SyncGroup.Request.V5 |
| $sel:attributes:Record | Kafka.Record.Response |
| $sel:authorizedOperations:Topic | Kafka.Metadata.Response.V12 |
| $sel:baseOffset:Partition | Kafka.Produce.Response.V9 |
| $sel:body:Request | Kafka.Message.Request.V2 |
| $sel:brokers:Response | Kafka.Metadata.Response.V12 |
| $sel:clientId:Header | Kafka.Message.Request.V2 |
| $sel:clientSoftwareName:Request | Kafka.ApiVersions.Request.V3 |
| $sel:clientSoftwareVersion:Request | Kafka.ApiVersions.Request.V3 |
| $sel:clusterId:Response | Kafka.Metadata.Response.V12 |
| $sel:committedLeaderEpoch:Partition | Kafka.OffsetFetch.Response.V8 |
| $sel:committedOffset:Partition | Kafka.OffsetFetch.Response.V8 |
| $sel:controllerId:Response | Kafka.Metadata.Response.V12 |
| $sel:coordinatorKeys:Request | Kafka.FindCoordinator.Request.V4 |
| $sel:coordinators:Response | Kafka.FindCoordinator.Response.V4 |
| $sel:correlationId:Header | |
| 1 (Function) | Kafka.Message.Request.V2 |
| 2 (Function) | Kafka.Header.Response.V0 |
| 3 (Function) | Kafka.Header.Response.V1 |
| $sel:currentLeaderEpoch:Partition | |
| 1 (Function) | Kafka.Fetch.Request.V13 |
| 2 (Function) | Kafka.ListOffsets.Request.V7 |
| $sel:errorCode:Coordinator | Kafka.FindCoordinator.Response.V4 |
| $sel:errorCode:Group | Kafka.OffsetFetch.Response.V8 |
| $sel:errorCode:Member | Kafka.LeaveGroup.Response.V5 |
| $sel:errorCode:Partition | |
| 1 (Function) | Kafka.Produce.Response.V9 |
| 2 (Function) | Kafka.OffsetFetch.Response.V8 |
| 3 (Function) | Kafka.Metadata.Response.V12 |
| 4 (Function) | Kafka.ListOffsets.Response.V7 |
| 5 (Function) | Kafka.Fetch.Response.V13 |
| $sel:errorCode:Response | |
| 1 (Function) | Kafka.JoinGroup.Response.V9 |
| 2 (Function) | Kafka.Heartbeat.Response.V4 |
| 3 (Function) | Kafka.SyncGroup.Response.V5 |
| 4 (Function) | Kafka.LeaveGroup.Response.V5 |
| 5 (Function) | Kafka.InitProducerId.Response.V4 |
| 6 (Function) | Kafka.Fetch.Response.V13 |
| 7 (Function) | Kafka.ApiVersions.Response.V3 |
| $sel:errorCode:Topic | Kafka.Metadata.Response.V12 |
| $sel:errorMessage:Coordinator | Kafka.FindCoordinator.Response.V4 |
| $sel:errorMessage:Partition | Kafka.Produce.Response.V9 |
| $sel:errors:Partition | Kafka.Produce.Response.V9 |
| $sel:fetchOffset:Partition | Kafka.Fetch.Request.V13 |
| $sel:generationId:Request | |
| 1 (Function) | Kafka.Heartbeat.Request.V4 |
| 2 (Function) | Kafka.SyncGroup.Request.V5 |
| $sel:generationId:Response | Kafka.JoinGroup.Response.V9 |
| $sel:groupId:Request | |
| 1 (Function) | Kafka.Heartbeat.Request.V4 |
| 2 (Function) | Kafka.JoinGroup.Request.V9 |
| 3 (Function) | Kafka.LeaveGroup.Request.V5 |
| 4 (Function) | Kafka.SyncGroup.Request.V5 |
| $sel:groupInstanceId:Member | |
| 1 (Function) | Kafka.LeaveGroup.Request.V5 |
| 2 (Function) | Kafka.JoinGroup.Response.V9 |
| 3 (Function) | Kafka.LeaveGroup.Response.V5 |
| $sel:groupInstanceId:Request | |
| 1 (Function) | Kafka.Heartbeat.Request.V4 |
| 2 (Function) | Kafka.JoinGroup.Request.V9 |
| 3 (Function) | Kafka.SyncGroup.Request.V5 |
| $sel:groups:Request | Kafka.OffsetFetch.Request.V8 |
| $sel:groups:Response | Kafka.OffsetFetch.Response.V8 |
| $sel:header:Headed | |
| 1 (Function) | Kafka.Header.Response.V0 |
| 2 (Function) | Kafka.Header.Response.V1 |
| $sel:header:Request | Kafka.Message.Request.V2 |
| $sel:headers:Record | |
| 1 (Function) | Kafka.Record.Request |
| 2 (Function) | Kafka.Record.Response |
| $sel:highWatermark:Partition | Kafka.Fetch.Response.V13 |
| $sel:host:Broker | Kafka.Metadata.Response.V12 |
| $sel:host:Coordinator | Kafka.FindCoordinator.Response.V4 |
| $sel:id:Group | |
| 1 (Function) | Kafka.OffsetFetch.Request.V8 |
| 2 (Function) | Kafka.OffsetFetch.Response.V8 |
| $sel:id:Topic | |
| 1 (Function) | Kafka.Fetch.Request.V13 |
| 2 (Function) | Kafka.Metadata.Request.V12 |
| 3 (Function) | Kafka.Metadata.Response.V12 |
| 4 (Function) | Kafka.Fetch.Response.V13 |
| $sel:includeTopicAuthorizedOperations:Request | Kafka.Metadata.Request.V12 |
| $sel:index:Error | |
| 1 (Function) | Kafka.Produce.Response.V9 |
| 2 (Function) | Kafka.Metadata.Response.V12 |
| $sel:index:Partition | |
| 1 (Function) | Kafka.Fetch.Request.V13 |
| 2 (Function) | Kafka.ListOffsets.Request.V7 |
| 3 (Function) | Kafka.Produce.Request.V9 |
| 4 (Function) | Kafka.Produce.Response.V9 |
| 5 (Function) | Kafka.OffsetFetch.Response.V8 |
| 6 (Function) | Kafka.Metadata.Response.V12 |
| 7 (Function) | Kafka.ListOffsets.Response.V7 |
| 8 (Function) | Kafka.Fetch.Response.V13 |
| $sel:internal:Topic | Kafka.Metadata.Response.V12 |
| $sel:isolationLevel:Request | |
| 1 (Function) | Kafka.Fetch.Request.V13 |
| 2 (Function) | Kafka.ListOffsets.Request.V7 |
| $sel:isrNodes:Partition | Kafka.Metadata.Response.V12 |
| $sel:key:Coordinator | Kafka.FindCoordinator.Response.V4 |
| $sel:key:Header | |
| 1 (Function) | Kafka.Record.Request |
| 2 (Function) | Kafka.Record.Response |
| $sel:key:Record | |
| 1 (Function) | Kafka.Record.Request |
| 2 (Function) | Kafka.Record.Response |
| $sel:keyType:Request | Kafka.FindCoordinator.Request.V4 |
| $sel:lastFetchedEpoch:Partition | Kafka.Fetch.Request.V13 |
| $sel:lastStableOffset:Partition | Kafka.Fetch.Response.V13 |
| $sel:leader:Response | Kafka.JoinGroup.Response.V9 |
| $sel:leaderEpoch:Partition | |
| 1 (Function) | Kafka.Metadata.Response.V12 |
| 2 (Function) | Kafka.ListOffsets.Response.V7 |
| $sel:leaderId:Partition | Kafka.Metadata.Response.V12 |
| $sel:logAppendTimeMilliseconds:Partition | Kafka.Produce.Response.V9 |
| $sel:logStartOffset:Partition | |
| 1 (Function) | Kafka.Fetch.Request.V13 |
| 2 (Function) | Kafka.Produce.Response.V9 |
| 3 (Function) | Kafka.Fetch.Response.V13 |
| $sel:maxBytes:Partition | Kafka.Fetch.Request.V13 |
| $sel:maxBytes:Request | Kafka.Fetch.Request.V13 |
| $sel:maxVersion:ApiKeyVersionSupport | Kafka.ApiVersions.Response.V3 |
| $sel:maxWaitMilliseconds:Request | Kafka.Fetch.Request.V13 |
| $sel:memberId:Assignment | Kafka.SyncGroup.Request.V5 |
| $sel:memberId:Member | |
| 1 (Function) | Kafka.LeaveGroup.Request.V5 |
| 2 (Function) | Kafka.JoinGroup.Response.V9 |
| 3 (Function) | Kafka.LeaveGroup.Response.V5 |
| $sel:memberId:Request | |
| 1 (Function) | Kafka.Heartbeat.Request.V4 |
| 2 (Function) | Kafka.JoinGroup.Request.V9 |
| 3 (Function) | Kafka.SyncGroup.Request.V5 |
| $sel:memberId:Response | Kafka.JoinGroup.Response.V9 |
| $sel:members:Request | Kafka.LeaveGroup.Request.V5 |
| $sel:members:Response | |
| 1 (Function) | Kafka.JoinGroup.Response.V9 |
| 2 (Function) | Kafka.LeaveGroup.Response.V5 |
| $sel:message:Error | |
| 1 (Function) | Kafka.Produce.Response.V9 |
| 2 (Function) | Kafka.Metadata.Response.V12 |
| $sel:metadata:Member | Kafka.JoinGroup.Response.V9 |
| $sel:metadata:Partition | Kafka.OffsetFetch.Response.V8 |
| $sel:metadata:Protocol | Kafka.JoinGroup.Request.V9 |
| $sel:minBytes:Request | Kafka.Fetch.Request.V13 |
| $sel:minVersion:ApiKeyVersionSupport | Kafka.ApiVersions.Response.V3 |
| $sel:name:Protocol | Kafka.JoinGroup.Request.V9 |
| $sel:name:Topic | |
| 1 (Function) | Kafka.ListOffsets.Request.V7 |
| 2 (Function) | Kafka.Metadata.Request.V12 |
| 3 (Function) | Kafka.OffsetFetch.Request.V8 |
| 4 (Function) | Kafka.Produce.Request.V9 |
| 5 (Function) | Kafka.Produce.Response.V9 |
| 6 (Function) | Kafka.OffsetFetch.Response.V8 |
| 7 (Function) | Kafka.Metadata.Response.V12 |
| 8 (Function) | Kafka.ListOffsets.Response.V7 |
| $sel:nodeId:Broker | Kafka.Metadata.Response.V12 |
| $sel:nodeId:Coordinator | Kafka.FindCoordinator.Response.V4 |
| $sel:offlineReplicas:Partition | Kafka.Metadata.Response.V12 |
| $sel:offset:Partition | Kafka.ListOffsets.Response.V7 |
| $sel:offsetDelta:Record | |
| 1 (Function) | Kafka.Record.Request |
| 2 (Function) | Kafka.Record.Response |
| $sel:ownedPartitions:Subscription | Kafka.Subscription.Request.V1, Kafka.Subscription.Response.V1 |
| $sel:partitions:Ownership | Kafka.Subscription.Request.V1, Kafka.Assignment.Request.V1, Kafka.Subscription.Response.V1, Kafka.Assignment.Response.V1 |
| $sel:partitions:Topic | |
| 1 (Function) | Kafka.Fetch.Request.V13 |
| 2 (Function) | Kafka.ListOffsets.Request.V7 |
| 3 (Function) | Kafka.OffsetFetch.Request.V8 |
| 4 (Function) | Kafka.Produce.Request.V9 |
| 5 (Function) | Kafka.Produce.Response.V9 |
| 6 (Function) | Kafka.OffsetFetch.Response.V8 |
| 7 (Function) | Kafka.Metadata.Response.V12 |
| 8 (Function) | Kafka.ListOffsets.Response.V7 |
| 9 (Function) | Kafka.Fetch.Response.V13 |
| $sel:port:Broker | Kafka.Metadata.Response.V12 |
| $sel:port:Coordinator | Kafka.FindCoordinator.Response.V4 |
| $sel:preferredReadReplica:Partition | Kafka.Fetch.Response.V13 |
| $sel:producerEpoch:Request | Kafka.InitProducerId.Request.V4 |
| $sel:producerEpoch:Response | Kafka.InitProducerId.Response.V4 |
| $sel:producerId:Request | Kafka.InitProducerId.Request.V4 |
| $sel:producerId:Response | Kafka.InitProducerId.Response.V4 |
| $sel:protocolName:Request | Kafka.SyncGroup.Request.V5 |
| $sel:protocolName:Response | |
| 1 (Function) | Kafka.JoinGroup.Response.V9 |
| 2 (Function) | Kafka.SyncGroup.Response.V5 |
| $sel:protocols:Request | Kafka.JoinGroup.Request.V9 |
| $sel:protocolType:Request | |
| 1 (Function) | Kafka.JoinGroup.Request.V9 |
| 2 (Function) | Kafka.SyncGroup.Request.V5 |
| $sel:protocolType:Response | |
| 1 (Function) | Kafka.JoinGroup.Response.V9 |
| 2 (Function) | Kafka.SyncGroup.Response.V5 |
| $sel:rack:Broker | Kafka.Metadata.Response.V12 |
| $sel:rackId:Request | Kafka.Fetch.Request.V13 |
| $sel:reason:Member | Kafka.LeaveGroup.Request.V5 |
| $sel:reason:Request | Kafka.JoinGroup.Request.V9 |
| $sel:rebalanceTimeoutMilliseconds:Request | Kafka.JoinGroup.Request.V9 |
| $sel:records:Partition | |
| 1 (Function) | Kafka.Produce.Request.V9 |
| 2 (Function) | Kafka.Fetch.Response.V13 |
| $sel:replicaId:Request | |
| 1 (Function) | Kafka.Fetch.Request.V13 |
| 2 (Function) | Kafka.ListOffsets.Request.V7 |
| $sel:replicaNodes:Partition | Kafka.Metadata.Response.V12 |
| $sel:requireStable:Request | Kafka.OffsetFetch.Request.V8 |
| $sel:response:Headed | |
| 1 (Function) | Kafka.Header.Response.V0 |
| 2 (Function) | Kafka.Header.Response.V1 |
| $sel:sessionEpoch:Request | Kafka.Fetch.Request.V13 |
| $sel:sessionId:Request | Kafka.Fetch.Request.V13 |
| $sel:sessionId:Response | Kafka.Fetch.Response.V13 |
| $sel:sessionTimeoutMilliseconds:Request | Kafka.JoinGroup.Request.V9 |
| $sel:skipAssignment:Response | Kafka.JoinGroup.Response.V9 |
| $sel:taggedFields:ApiKeyVersionSupport | Kafka.ApiVersions.Response.V3 |
| $sel:taggedFields:Broker | Kafka.Metadata.Response.V12 |
| $sel:taggedFields:Coordinator | Kafka.FindCoordinator.Response.V4 |
| $sel:taggedFields:Error | |
| 1 (Function) | Kafka.Produce.Response.V9 |
| 2 (Function) | Kafka.Metadata.Response.V12 |
| $sel:taggedFields:Group | Kafka.OffsetFetch.Response.V8 |
| $sel:taggedFields:Header | Kafka.Header.Response.V1 |
| $sel:taggedFields:Member | |
| 1 (Function) | Kafka.JoinGroup.Response.V9 |
| 2 (Function) | Kafka.LeaveGroup.Response.V5 |
| $sel:taggedFields:Partition | |
| 1 (Function) | Kafka.Produce.Response.V9 |
| 2 (Function) | Kafka.OffsetFetch.Response.V8 |
| 3 (Function) | Kafka.Metadata.Response.V12 |
| 4 (Function) | Kafka.ListOffsets.Response.V7 |
| 5 (Function) | Kafka.Fetch.Response.V13 |
| $sel:taggedFields:Response | |
| 1 (Function) | Kafka.JoinGroup.Response.V9 |
| 2 (Function) | Kafka.Heartbeat.Response.V4 |
| 3 (Function) | Kafka.SyncGroup.Response.V5 |
| 4 (Function) | Kafka.Produce.Response.V9 |
| 5 (Function) | Kafka.OffsetFetch.Response.V8 |
| 6 (Function) | Kafka.Metadata.Response.V12 |
| 7 (Function) | Kafka.ListOffsets.Response.V7 |
| 8 (Function) | Kafka.LeaveGroup.Response.V5 |
| 9 (Function) | Kafka.InitProducerId.Response.V4 |
| 10 (Function) | Kafka.FindCoordinator.Response.V4 |
| 11 (Function) | Kafka.Fetch.Response.V13 |
| 12 (Function) | Kafka.ApiVersions.Response.V3 |
| $sel:taggedFields:Topic | |
| 1 (Function) | Kafka.Produce.Response.V9 |
| 2 (Function) | Kafka.OffsetFetch.Response.V8 |
| 3 (Function) | Kafka.Metadata.Response.V12 |
| 4 (Function) | Kafka.ListOffsets.Response.V7 |
| 5 (Function) | Kafka.Fetch.Response.V13 |
| $sel:throttleTimeMilliseconds:Response | |
| 1 (Function) | Kafka.JoinGroup.Response.V9 |
| 2 (Function) | Kafka.Heartbeat.Response.V4 |
| 3 (Function) | Kafka.SyncGroup.Response.V5 |
| 4 (Function) | Kafka.Produce.Response.V9 |
| 5 (Function) | Kafka.OffsetFetch.Response.V8 |
| 6 (Function) | Kafka.Metadata.Response.V12 |
| 7 (Function) | Kafka.ListOffsets.Response.V7 |
| 8 (Function) | Kafka.LeaveGroup.Response.V5 |
| 9 (Function) | Kafka.InitProducerId.Response.V4 |
| 10 (Function) | Kafka.FindCoordinator.Response.V4 |
| 11 (Function) | Kafka.Fetch.Response.V13 |
| 12 (Function) | Kafka.ApiVersions.Response.V3 |
| $sel:timeoutMilliseconds:Request | Kafka.Produce.Request.V9 |
| $sel:timestamp:Partition | |
| 1 (Function) | Kafka.ListOffsets.Request.V7 |
| 2 (Function) | Kafka.ListOffsets.Response.V7 |
| $sel:timestampDelta:Record | |
| 1 (Function) | Kafka.Record.Request |
| 2 (Function) | Kafka.Record.Response |
| $sel:topic:Ownership | Kafka.Subscription.Request.V1, Kafka.Assignment.Request.V1, Kafka.Subscription.Response.V1, Kafka.Assignment.Response.V1 |
| $sel:topicData:Request | Kafka.Produce.Request.V9 |
| $sel:topics:Group | |
| 1 (Function) | Kafka.OffsetFetch.Request.V8 |
| 2 (Function) | Kafka.OffsetFetch.Response.V8 |
| $sel:topics:Request | |
| 1 (Function) | Kafka.Fetch.Request.V13 |
| 2 (Function) | Kafka.ListOffsets.Request.V7 |
| 3 (Function) | Kafka.Metadata.Request.V12 |
| $sel:topics:Response | |
| 1 (Function) | Kafka.Produce.Response.V9 |
| 2 (Function) | Kafka.Metadata.Response.V12 |
| 3 (Function) | Kafka.ListOffsets.Response.V7 |
| 4 (Function) | Kafka.Fetch.Response.V13 |
| $sel:topics:Subscription | Kafka.Subscription.Request.V1, Kafka.Subscription.Response.V1 |
| $sel:transactionalId:Request | |
| 1 (Function) | Kafka.InitProducerId.Request.V4 |
| 2 (Function) | Kafka.Produce.Request.V9 |
| $sel:transactionTimeoutMilliseconds:Request | Kafka.InitProducerId.Request.V4 |
| $sel:userData:Assignment | Kafka.Assignment.Request.V1, Kafka.Assignment.Response.V1 |
| $sel:userData:Subscription | Kafka.Subscription.Request.V1, Kafka.Subscription.Response.V1 |
| $sel:value:Header | |
| 1 (Function) | Kafka.Record.Request |
| 2 (Function) | Kafka.Record.Response |
| $sel:value:Record | |
| 1 (Function) | Kafka.Record.Request |
| 2 (Function) | Kafka.Record.Response |
| AbortedTransactions | Kafka.Parser.Context |
| Acknowledgments | |
| 1 (Type/Class) | Kafka.Acknowledgments |
| 2 (Data Constructor) | Kafka.Acknowledgments |
| AddOffsetsToTxn | Kafka.ApiKey |
| AddPartitionsToTxn | Kafka.ApiKey |
| all | Kafka.Metadata.Request.V12 |
| AlterConfigs | Kafka.ApiKey |
| AlterPartitionReassignments | Kafka.ApiKey |
| AlterReplicaLogDirs | Kafka.ApiKey |
| ApiKey | |
| 1 (Type/Class) | Kafka.ApiKey |
| 2 (Data Constructor) | Kafka.ApiKey |
| 3 (Data Constructor) | Kafka.Parser.Context |
| apiKey | |
| 1 (Function) | Kafka.JoinGroup.V9 |
| 2 (Function) | Kafka.Heartbeat.V4 |
| 3 (Function) | Kafka.SyncGroup.V5 |
| 4 (Function) | Kafka.Produce.V9 |
| 5 (Function) | Kafka.OffsetFetch.V8 |
| 6 (Function) | Kafka.Metadata.V12 |
| 7 (Function) | Kafka.ListOffsets.V7 |
| 8 (Function) | Kafka.LeaveGroup.V5 |
| 9 (Function) | Kafka.InitProducerId.V4 |
| 10 (Function) | Kafka.FindCoordinator.V4 |
| 11 (Function) | Kafka.Fetch.V13 |
| 12 (Function) | Kafka.ApiVersions.V3 |
| ApiKeys | Kafka.Parser.Context |
| ApiKeyVersionSupport | |
| 1 (Type/Class) | Kafka.ApiVersions.Response.V3 |
| 2 (Data Constructor) | Kafka.ApiVersions.Response.V3 |
| apiVersion | |
| 1 (Function) | Kafka.ApiVersions.Request.V3 |
| 2 (Function) | Kafka.JoinGroup.V9 |
| 3 (Function) | Kafka.Heartbeat.V4 |
| 4 (Function) | Kafka.SyncGroup.V5 |
| 5 (Function) | Kafka.Produce.V9 |
| 6 (Function) | Kafka.OffsetFetch.V8 |
| 7 (Function) | Kafka.Metadata.V12 |
| 8 (Function) | Kafka.ListOffsets.V7 |
| 9 (Function) | Kafka.LeaveGroup.V5 |
| 10 (Function) | Kafka.InitProducerId.V4 |
| 11 (Function) | Kafka.FindCoordinator.V4 |
| 12 (Function) | Kafka.Fetch.V13 |
| 13 (Function) | Kafka.ApiVersions.V3 |
| ApiVersions | Kafka.ApiKey |
| AssignedPartitions | Kafka.Parser.Context |
| Assignment | |
| 1 (Data Constructor) | Kafka.Parser.Context |
| 2 (Type/Class) | Kafka.Assignment.Request.V1, Kafka.Assignment.Response.V1 |
| 3 (Data Constructor) | Kafka.Assignment.Request.V1, Kafka.Assignment.Response.V1 |
| 4 (Type/Class) | Kafka.SyncGroup.Request.V5 |
| 5 (Data Constructor) | Kafka.SyncGroup.Request.V5 |
| Attributes | Kafka.Parser.Context |
| attributes | |
| 1 (Function) | Kafka.RecordBatch.Request |
| 2 (Function) | Kafka.RecordBatch.Response |
| AuthorizedOperations | Kafka.Parser.Context |
| BaseOffset | Kafka.Parser.Context |
| baseOffset | |
| 1 (Function) | Kafka.RecordBatch.Request |
| 2 (Function) | Kafka.RecordBatch.Response |
| BaseSequence | Kafka.Parser.Context |
| baseSequence | |
| 1 (Function) | Kafka.RecordBatch.Request |
| 2 (Function) | Kafka.RecordBatch.Response |
| BaseTimestamp | Kafka.Parser.Context |
| baseTimestamp | |
| 1 (Function) | Kafka.RecordBatch.Request |
| 2 (Function) | Kafka.RecordBatch.Response |
| BatchLength | Kafka.Parser.Context |
| BatchLengthLeftoverBytes | Kafka.Parser.Context |
| BatchLengthNegative | Kafka.Parser.Context |
| BatchLengthNotEnoughBytes | Kafka.Parser.Context |
| Broker | |
| 1 (Type/Class) | Kafka.Metadata.Response.V12 |
| 2 (Data Constructor) | Kafka.Metadata.Response.V12 |
| BrokerIdNotRegistered | Kafka.ErrorCode |
| BrokerNotAvailable | Kafka.ErrorCode |
| Brokers | Kafka.Parser.Context |
| ClusterAuthorizationFailed | Kafka.ErrorCode |
| ClusterId | Kafka.Parser.Context |
| CommittedLeaderEpoch | Kafka.Parser.Context |
| CommittedOffset | Kafka.Parser.Context |
| Compression | Kafka.RecordBatch.Attributes |
| ConcurrentTransactions | Kafka.ErrorCode |
| contents | Kafka.TaggedField |
| Context | Kafka.Parser.Context |
| context | |
| 1 (Function) | Kafka.Exchange.Error |
| 2 (Function) | Kafka.Parser.Context |
| ContextualizedErrorCode | |
| 1 (Type/Class) | Kafka.Parser.Context |
| 2 (Data Constructor) | Kafka.Parser.Context |
| ControlledShutdown | Kafka.ApiKey |
| ControllerId | Kafka.Parser.Context |
| Coordinator | |
| 1 (Type/Class) | Kafka.FindCoordinator.Response.V4 |
| 2 (Data Constructor) | Kafka.FindCoordinator.Response.V4 |
| CoordinatorLoadInProgress | Kafka.ErrorCode |
| CoordinatorNotAvailable | Kafka.ErrorCode |
| Coordinators | Kafka.Parser.Context |
| CorrelationId | Kafka.Parser.Context |
| CorruptMessage | Kafka.ErrorCode |
| Crc | Kafka.Parser.Context |
| CrcMismatch | Kafka.Parser.Context |
| CreateAcls | Kafka.ApiKey |
| CreateDelegationToken | Kafka.ApiKey |
| CreatePartitions | Kafka.ApiKey |
| CreateTime | Kafka.RecordBatch.Attributes |
| CreateTopics | Kafka.ApiKey |
| decode | |
| 1 (Function) | Kafka.Header.Response.V0 |
| 2 (Function) | Kafka.Subscription.Response.V1 |
| 3 (Function) | Kafka.Assignment.Response.V1 |
| 4 (Function) | Kafka.JoinGroup.Response.V9, Kafka.JoinGroup.V9 |
| 5 (Function) | Kafka.Heartbeat.Response.V4, Kafka.Heartbeat.V4 |
| 6 (Function) | Kafka.Header.Response.V1 |
| 7 (Function) | Kafka.SyncGroup.Response.V5, Kafka.SyncGroup.V5 |
| 8 (Function) | Kafka.Produce.Response.V9, Kafka.Produce.V9 |
| 9 (Function) | Kafka.OffsetFetch.Response.V8, Kafka.OffsetFetch.V8 |
| 10 (Function) | Kafka.Metadata.Response.V12, Kafka.Metadata.V12 |
| 11 (Function) | Kafka.ListOffsets.Response.V7, Kafka.ListOffsets.V7 |
| 12 (Function) | Kafka.LeaveGroup.Response.V5, Kafka.LeaveGroup.V5 |
| 13 (Function) | Kafka.InitProducerId.Response.V4, Kafka.InitProducerId.V4 |
| 14 (Function) | Kafka.FindCoordinator.Response.V4, Kafka.FindCoordinator.V4 |
| 15 (Function) | Kafka.Fetch.Response.V13, Kafka.Fetch.V13 |
| 16 (Function) | Kafka.ApiVersions.Response.V3, Kafka.ApiVersions.V3 |
| decodeArray | Kafka.Record.Response |
| decodeArrayAbsolute | Kafka.Record.Response |
| decodeHeaded | |
| 1 (Function) | Kafka.JoinGroup.Response.V9 |
| 2 (Function) | Kafka.SyncGroup.Response.V5 |
| 3 (Function) | Kafka.Produce.Response.V9 |
| 4 (Function) | Kafka.Metadata.Response.V12 |
| 5 (Function) | Kafka.ListOffsets.Response.V7 |
| 6 (Function) | Kafka.InitProducerId.Response.V4 |
| 7 (Function) | Kafka.FindCoordinator.Response.V4 |
| 8 (Function) | Kafka.Fetch.Response.V13 |
| 9 (Function) | Kafka.ApiVersions.Response.V3 |
| DelegationTokenAuthDisabled | Kafka.ErrorCode |
| DelegationTokenAuthorizationFailed | Kafka.ErrorCode |
| DelegationTokenExpired | Kafka.ErrorCode |
| DelegationTokenNotFound | Kafka.ErrorCode |
| DelegationTokenOwnerMismatch | Kafka.ErrorCode |
| DelegationTokenRequestNotAllowed | Kafka.ErrorCode |
| DeleteAcls | Kafka.ApiKey |
| DeleteGroups | Kafka.ApiKey |
| DeleteRecords | Kafka.ApiKey |
| DeleteTopics | Kafka.ApiKey |
| DescribeAcls | Kafka.ApiKey |
| DescribeConfigs | Kafka.ApiKey |
| DescribeDelegationToken | Kafka.ApiKey |
| DescribeGroups | Kafka.ApiKey |
| DescribeLogDirs | Kafka.ApiKey |
| DuplicateBrokerRegistration | Kafka.ErrorCode |
| DuplicateResource | Kafka.ErrorCode |
| DuplicateSequenceNumber | Kafka.ErrorCode |
| ElectionNotNeeded | Kafka.ErrorCode |
| ElectLeaders | Kafka.ApiKey |
| EligibleLeadersNotAvailable | Kafka.ErrorCode |
| encode | Kafka.Produce.Request.V9 |
| encodeContextString | Kafka.Parser.Context |
| encodeOwnership | Kafka.Subscription.Request.V1 |
| End | Kafka.Parser.Context |
| EndTxn | Kafka.ApiKey |
| Error | |
| 1 (Type/Class) | Kafka.Exchange.Error |
| 2 (Data Constructor) | Kafka.Exchange.Error |
| 3 (Type/Class) | Kafka.Produce.Response.V9 |
| 4 (Data Constructor) | Kafka.Produce.Response.V9 |
| 5 (Type/Class) | Kafka.Metadata.Response.V12 |
| 6 (Data Constructor) | Kafka.Metadata.Response.V12 |
| ErrorCode | |
| 1 (Type/Class) | Kafka.ErrorCode |
| 2 (Data Constructor) | Kafka.ErrorCode |
| 3 (Data Constructor) | Kafka.Parser.Context |
| errorCode | Kafka.Parser.Context |
| ErrorMessage | Kafka.Parser.Context |
| Errors | Kafka.Parser.Context |
| ExpireDelegationToken | Kafka.ApiKey |
| FeatureUpdateFailed | Kafka.ErrorCode |
| FencedInstanceId | Kafka.ErrorCode |
| FencedLeaderEpoch | Kafka.ErrorCode |
| Fetch | Kafka.ApiKey |
| FetchSessionIdNotFound | Kafka.ErrorCode |
| FetchSessionTopicIdError | Kafka.ErrorCode |
| Field | |
| 1 (Type/Class) | Kafka.Parser.Context |
| 2 (Data Constructor) | Kafka.Parser.Context |
| FindCoordinator | Kafka.ApiKey |
| findErrorCode | Kafka.Metadata.Response.V12 |
| FullIsr | Kafka.Acknowledgments |
| GenerationId | Kafka.Parser.Context |
| getCompression | Kafka.RecordBatch.Attributes |
| getTimestampType | Kafka.RecordBatch.Attributes |
| Group | |
| 1 (Type/Class) | Kafka.OffsetFetch.Request.V8 |
| 2 (Data Constructor) | Kafka.OffsetFetch.Request.V8 |
| 3 (Type/Class) | Kafka.OffsetFetch.Response.V8 |
| 4 (Data Constructor) | Kafka.OffsetFetch.Response.V8 |
| GroupAuthorizationFailed | Kafka.ErrorCode |
| GroupIdNotFound | Kafka.ErrorCode |
| GroupInstanceId | Kafka.Parser.Context |
| GroupMaxSizeReached | Kafka.ErrorCode |
| Groups | Kafka.Parser.Context |
| GroupSubscribedToTopic | Kafka.ErrorCode |
| Gzip | Kafka.RecordBatch.Attributes |
| hasErrorCode | Kafka.Metadata.Response.V12 |
| Headed | |
| 1 (Type/Class) | Kafka.Header.Response.V0 |
| 2 (Data Constructor) | Kafka.Header.Response.V0 |
| 3 (Type/Class) | Kafka.Header.Response.V1 |
| 4 (Data Constructor) | Kafka.Header.Response.V1 |
| Header | |
| 1 (Type/Class) | Kafka.Message.Request.V2 |
| 2 (Data Constructor) | Kafka.Message.Request.V2 |
| 3 (Type/Class) | Kafka.Header.Response.V0 |
| 4 (Data Constructor) | Kafka.Header.Response.V0 |
| 5 (Type/Class) | Kafka.Record.Request |
| 6 (Data Constructor) | Kafka.Record.Request |
| 7 (Type/Class) | Kafka.Record.Response |
| 8 (Data Constructor) | Kafka.Record.Response |
| 9 (Type/Class) | Kafka.Header.Response.V1 |
| 10 (Data Constructor) | Kafka.Header.Response.V1 |
| Heartbeat | Kafka.ApiKey |
| HighWatermark | Kafka.Parser.Context |
| Host | Kafka.Parser.Context |
| Id | Kafka.Parser.Context |
| IllegalGeneration | Kafka.ErrorCode |
| IllegalSaslState | Kafka.ErrorCode |
| InconsistentClusterId | Kafka.ErrorCode |
| InconsistentGroupProtocol | Kafka.ErrorCode |
| InconsistentTopicId | Kafka.ErrorCode |
| InconsistentVoterSet | Kafka.ErrorCode |
| IncrementalAlterConfigs | Kafka.ApiKey |
| Index | Kafka.Parser.Context |
| IneligibleReplica | Kafka.ErrorCode |
| InitProducerId | Kafka.ApiKey |
| Internal | Kafka.Parser.Context |
| InvalidCommitOffsetSize | Kafka.ErrorCode |
| InvalidConfig | Kafka.ErrorCode |
| InvalidFetchSessionEpoch | Kafka.ErrorCode |
| InvalidFetchSize | Kafka.ErrorCode |
| InvalidGroupId | Kafka.ErrorCode |
| InvalidPartitions | Kafka.ErrorCode |
| InvalidPrincipalType | Kafka.ErrorCode |
| InvalidProducerEpoch | Kafka.ErrorCode |
| InvalidProducerIdMapping | Kafka.ErrorCode |
| InvalidRecord | Kafka.ErrorCode |
| InvalidReplicaAssignment | Kafka.ErrorCode |
| InvalidReplicationFactor | Kafka.ErrorCode |
| InvalidRequest | Kafka.ErrorCode |
| InvalidRequiredAcks | Kafka.ErrorCode |
| InvalidSessionTimeout | Kafka.ErrorCode |
| InvalidTimestamp | Kafka.ErrorCode |
| InvalidTopicException | Kafka.ErrorCode |
| InvalidTransactionTimeout | Kafka.ErrorCode |
| InvalidTxnState | Kafka.ErrorCode |
| InvalidUpdateVersion | Kafka.ErrorCode |
| IsrNodes | Kafka.Parser.Context |
| Ix | Kafka.Parser.Context |
| JoinGroup | Kafka.ApiKey |
| KafkaStorageError | Kafka.ErrorCode |
| Key | Kafka.Parser.Context |
| LastOffsetDelta | Kafka.Parser.Context |
| lastOffsetDelta | |
| 1 (Function) | Kafka.RecordBatch.Request |
| 2 (Function) | Kafka.RecordBatch.Response |
| LastStableOffset | Kafka.Parser.Context |
| Leader | Kafka.Parser.Context |
| LeaderAndIsr | Kafka.ApiKey |
| LeaderEpoch | Kafka.Parser.Context |
| LeaderId | Kafka.Parser.Context |
| LeaderNotAvailable | Kafka.ErrorCode |
| LeaderOnly | Kafka.Acknowledgments |
| LeaveGroup | Kafka.ApiKey |
| ListenerNotFound | Kafka.ErrorCode |
| ListGroups | Kafka.ApiKey |
| ListOffsets | Kafka.ApiKey |
| ListPartitionReassignments | Kafka.ApiKey |
| LogAppendTime | Kafka.RecordBatch.Attributes |
| LogAppendTimeMilliseconds | Kafka.Parser.Context |
| LogDirNotFound | Kafka.ErrorCode |
| LogStartOffset | Kafka.Parser.Context |
| Lz4 | Kafka.RecordBatch.Attributes |
| Magic | Kafka.Parser.Context |
| MaxTimestamp | Kafka.Parser.Context |
| maxTimestamp | |
| 1 (Function) | Kafka.RecordBatch.Request |
| 2 (Function) | Kafka.RecordBatch.Response |
| MaxVersion | Kafka.Parser.Context |
| Member | |
| 1 (Type/Class) | Kafka.LeaveGroup.Request.V5 |
| 2 (Data Constructor) | Kafka.LeaveGroup.Request.V5 |
| 3 (Type/Class) | Kafka.JoinGroup.Response.V9 |
| 4 (Data Constructor) | Kafka.JoinGroup.Response.V9 |
| 5 (Type/Class) | Kafka.LeaveGroup.Response.V5 |
| 6 (Data Constructor) | Kafka.LeaveGroup.Response.V5 |
| MemberId | Kafka.Parser.Context |
| MemberIdRequired | Kafka.ErrorCode |
| Members | Kafka.Parser.Context |
| Message | |
| 1 (Type/Class) | Kafka.Exchange.Error |
| 2 (Data Constructor) | Kafka.Parser.Context |
| message | Kafka.Exchange.Error |
| MessageTooLarge | Kafka.ErrorCode |
| Metadata | |
| 1 (Data Constructor) | Kafka.ApiKey |
| 2 (Data Constructor) | Kafka.Parser.Context |
| MinVersion | Kafka.Parser.Context |
| Name | Kafka.Parser.Context |
| NetworkException | Kafka.ErrorCode |
| NewLeaderElected | Kafka.ErrorCode |
| NodeId | Kafka.Parser.Context |
| None | |
| 1 (Data Constructor) | Kafka.Acknowledgments |
| 2 (Data Constructor) | Kafka.ErrorCode |
| 3 (Data Constructor) | Kafka.RecordBatch.Attributes |
| none | Kafka.Metadata.Request.V12 |
| NonEmptyGroup | Kafka.ErrorCode |
| NoReassignmentInProgress | Kafka.ErrorCode |
| NotController | Kafka.ErrorCode |
| NotCoordinator | Kafka.ErrorCode |
| NotEnoughReplicas | Kafka.ErrorCode |
| NotEnoughReplicasAfterAppend | Kafka.ErrorCode |
| NotLeaderOrFollower | Kafka.ErrorCode |
| OfflineReplicas | Kafka.Parser.Context |
| Offset | Kafka.Parser.Context |
| OffsetCommit | Kafka.ApiKey |
| OffsetDelete | Kafka.ApiKey |
| OffsetFetch | Kafka.ApiKey |
| OffsetForLeaderEpoch | Kafka.ApiKey |
| OffsetMetadataTooLarge | Kafka.ErrorCode |
| OffsetNotAvailable | Kafka.ErrorCode |
| OffsetOutOfRange | Kafka.ErrorCode |
| OperationNotAttempted | Kafka.ErrorCode |
| OutOfOrderSequenceNumber | Kafka.ErrorCode |
| OwnedPartitions | Kafka.Parser.Context |
| Ownership | |
| 1 (Type/Class) | Kafka.Subscription.Request.V1, Kafka.Assignment.Request.V1, Kafka.Subscription.Response.V1, Kafka.Assignment.Response.V1 |
| 2 (Data Constructor) | Kafka.Subscription.Request.V1, Kafka.Assignment.Request.V1, Kafka.Subscription.Response.V1, Kafka.Assignment.Response.V1 |
| parser | |
| 1 (Function) | Kafka.Header.Response.V0 |
| 2 (Function) | Kafka.RecordBatch.Response |
| 3 (Function) | Kafka.Subscription.Response.V1 |
| 4 (Function) | Kafka.Assignment.Response.V1 |
| 5 (Function) | Kafka.TaggedField |
| 6 (Function) | Kafka.JoinGroup.Response.V9 |
| 7 (Function) | Kafka.Heartbeat.Response.V4 |
| 8 (Function) | Kafka.Header.Response.V1 |
| 9 (Function) | Kafka.SyncGroup.Response.V5 |
| 10 (Function) | Kafka.Produce.Response.V9 |
| 11 (Function) | Kafka.OffsetFetch.Response.V8 |
| 12 (Function) | Kafka.Metadata.Response.V12 |
| 13 (Function) | Kafka.ListOffsets.Response.V7 |
| 14 (Function) | Kafka.LeaveGroup.Response.V5 |
| 15 (Function) | Kafka.InitProducerId.Response.V4 |
| 16 (Function) | Kafka.FindCoordinator.Response.V4 |
| 17 (Function) | Kafka.Fetch.Response.V13 |
| 18 (Function) | Kafka.ApiVersions.Response.V3 |
| parserArray | Kafka.RecordBatch.Response |
| parserMany | Kafka.TaggedField |
| parserOwnership | Kafka.Subscription.Response.V1 |
| Partition | |
| 1 (Type/Class) | Kafka.Fetch.Request.V13 |
| 2 (Data Constructor) | Kafka.Fetch.Request.V13 |
| 3 (Type/Class) | Kafka.ListOffsets.Request.V7 |
| 4 (Data Constructor) | Kafka.ListOffsets.Request.V7 |
| 5 (Type/Class) | Kafka.Produce.Request.V9 |
| 6 (Data Constructor) | Kafka.Produce.Request.V9 |
| 7 (Type/Class) | Kafka.Produce.Response.V9 |
| 8 (Data Constructor) | Kafka.Produce.Response.V9 |
| 9 (Type/Class) | Kafka.OffsetFetch.Response.V8 |
| 10 (Data Constructor) | Kafka.OffsetFetch.Response.V8 |
| 11 (Type/Class) | Kafka.Metadata.Response.V12 |
| 12 (Data Constructor) | Kafka.Metadata.Response.V12 |
| 13 (Type/Class) | Kafka.ListOffsets.Response.V7 |
| 14 (Data Constructor) | Kafka.ListOffsets.Response.V7 |
| 15 (Type/Class) | Kafka.Fetch.Response.V13 |
| 16 (Data Constructor) | Kafka.Fetch.Response.V13 |
| PartitionLeaderEpoch | Kafka.Parser.Context |
| partitionLeaderEpoch | |
| 1 (Function) | Kafka.RecordBatch.Request |
| 2 (Function) | Kafka.RecordBatch.Response |
| Partitions | Kafka.Parser.Context |
| PolicyViolation | Kafka.ErrorCode |
| Port | Kafka.Parser.Context |
| PositionOutOfRange | Kafka.ErrorCode |
| PreferredLeaderNotAvailable | Kafka.ErrorCode |
| PreferredReadReplica | Kafka.Parser.Context |
| PrincipalDeserializationFailure | Kafka.ErrorCode |
| Produce | Kafka.ApiKey |
| ProducerEpoch | Kafka.Parser.Context |
| producerEpoch | |
| 1 (Function) | Kafka.RecordBatch.Request |
| 2 (Function) | Kafka.RecordBatch.Response |
| ProducerFenced | Kafka.ErrorCode |
| ProducerId | Kafka.Parser.Context |
| producerId | |
| 1 (Function) | Kafka.RecordBatch.Request |
| 2 (Function) | Kafka.RecordBatch.Response |
| Protocol | |
| 1 (Type/Class) | Kafka.JoinGroup.Request.V9 |
| 2 (Data Constructor) | Kafka.JoinGroup.Request.V9 |
| ProtocolName | Kafka.Parser.Context |
| ProtocolType | Kafka.Parser.Context |
| Rack | Kafka.Parser.Context |
| ReassignmentInProgress | Kafka.ErrorCode |
| RebalanceInProgress | Kafka.ErrorCode |
| Record | |
| 1 (Type/Class) | Kafka.Record.Request |
| 2 (Data Constructor) | Kafka.Record.Request |
| 3 (Type/Class) | Kafka.Record.Response |
| 4 (Data Constructor) | Kafka.Record.Response |
| RecordBatch | |
| 1 (Data Constructor) | Kafka.Parser.Context |
| 2 (Type/Class) | Kafka.RecordBatch.Request |
| 3 (Data Constructor) | Kafka.RecordBatch.Request |
| 4 (Type/Class) | Kafka.RecordBatch.Response |
| 5 (Data Constructor) | Kafka.RecordBatch.Response |
| RecordBatchLeftoverBytes | Kafka.Parser.Context |
| RecordBatchLength | Kafka.Parser.Context |
| RecordBatchNotEnoughBytes | Kafka.Parser.Context |
| RecordListTooLarge | Kafka.ErrorCode |
| RecordsCount | Kafka.Parser.Context |
| recordsCount | |
| 1 (Function) | Kafka.RecordBatch.Request |
| 2 (Function) | Kafka.RecordBatch.Response |
| recordsPayload | |
| 1 (Function) | Kafka.RecordBatch.Request |
| 2 (Function) | Kafka.RecordBatch.Response |
| RenewDelegationToken | Kafka.ApiKey |
| ReplicaNodes | Kafka.Parser.Context |
| ReplicaNotAvailable | Kafka.ErrorCode |
| Request | |
| 1 (Type/Class) | Kafka.ApiVersions.Request.V3, Kafka.ApiVersions.V3 |
| 2 (Data Constructor) | Kafka.ApiVersions.Request.V3 |
| 3 (Type/Class) | Kafka.Fetch.Request.V13, Kafka.Fetch.V13 |
| 4 (Data Constructor) | Kafka.Fetch.Request.V13 |
| 5 (Type/Class) | Kafka.FindCoordinator.Request.V4, Kafka.FindCoordinator.V4 |
| 6 (Data Constructor) | Kafka.FindCoordinator.Request.V4 |
| 7 (Type/Class) | Kafka.Heartbeat.Request.V4, Kafka.Heartbeat.V4 |
| 8 (Data Constructor) | Kafka.Heartbeat.Request.V4 |
| 9 (Type/Class) | Kafka.InitProducerId.Request.V4, Kafka.InitProducerId.V4 |
| 10 (Data Constructor) | Kafka.InitProducerId.Request.V4, Kafka.InitProducerId.V4 |
| 11 (Type/Class) | Kafka.JoinGroup.Request.V9, Kafka.JoinGroup.V9 |
| 12 (Data Constructor) | Kafka.JoinGroup.Request.V9 |
| 13 (Type/Class) | Kafka.LeaveGroup.Request.V5, Kafka.LeaveGroup.V5 |
| 14 (Data Constructor) | Kafka.LeaveGroup.Request.V5 |
| 15 (Type/Class) | Kafka.ListOffsets.Request.V7, Kafka.ListOffsets.V7 |
| 16 (Data Constructor) | Kafka.ListOffsets.Request.V7 |
| 17 (Type/Class) | Kafka.Message.Request.V2 |
| 18 (Data Constructor) | Kafka.Message.Request.V2 |
| 19 (Type/Class) | Kafka.Metadata.Request.V12, Kafka.Metadata.V12 |
| 20 (Data Constructor) | Kafka.Metadata.Request.V12 |
| 21 (Type/Class) | Kafka.OffsetFetch.Request.V8, Kafka.OffsetFetch.V8 |
| 22 (Data Constructor) | Kafka.OffsetFetch.Request.V8 |
| 23 (Type/Class) | Kafka.Produce.Request.V9, Kafka.Produce.V9 |
| 24 (Data Constructor) | Kafka.Produce.Request.V9 |
| 25 (Type/Class) | Kafka.SyncGroup.Request.V5, Kafka.SyncGroup.V5 |
| 26 (Data Constructor) | Kafka.SyncGroup.Request.V5 |
| request | Kafka.InitProducerId.Request.V4 |
| RequestMessageNotSent | Kafka.Exchange.Error |
| RequestTimedOut | Kafka.ErrorCode |
| ResourceNotFound | Kafka.ErrorCode |
| Response | |
| 1 (Type/Class) | Kafka.JoinGroup.Response.V9, Kafka.JoinGroup.V9 |
| 2 (Data Constructor) | Kafka.JoinGroup.Response.V9 |
| 3 (Type/Class) | Kafka.Heartbeat.Response.V4, Kafka.Heartbeat.V4 |
| 4 (Data Constructor) | Kafka.Heartbeat.Response.V4 |
| 5 (Type/Class) | Kafka.SyncGroup.Response.V5, Kafka.SyncGroup.V5 |
| 6 (Data Constructor) | Kafka.SyncGroup.Response.V5 |
| 7 (Type/Class) | Kafka.Produce.Response.V9, Kafka.Produce.V9 |
| 8 (Data Constructor) | Kafka.Produce.Response.V9 |
| 9 (Type/Class) | Kafka.OffsetFetch.Response.V8, Kafka.OffsetFetch.V8 |
| 10 (Data Constructor) | Kafka.OffsetFetch.Response.V8 |
| 11 (Type/Class) | Kafka.Metadata.Response.V12, Kafka.Metadata.V12 |
| 12 (Data Constructor) | Kafka.Metadata.Response.V12 |
| 13 (Type/Class) | Kafka.ListOffsets.Response.V7, Kafka.ListOffsets.V7 |
| 14 (Data Constructor) | Kafka.ListOffsets.Response.V7 |
| 15 (Type/Class) | Kafka.LeaveGroup.Response.V5, Kafka.LeaveGroup.V5 |
| 16 (Data Constructor) | Kafka.LeaveGroup.Response.V5 |
| 17 (Type/Class) | Kafka.InitProducerId.Response.V4, Kafka.InitProducerId.V4 |
| 18 (Data Constructor) | Kafka.InitProducerId.Response.V4, Kafka.InitProducerId.V4 |
| 19 (Type/Class) | Kafka.FindCoordinator.Response.V4, Kafka.FindCoordinator.V4 |
| 20 (Data Constructor) | Kafka.FindCoordinator.Response.V4 |
| 21 (Type/Class) | Kafka.Fetch.Response.V13, Kafka.Fetch.V13 |
| 22 (Data Constructor) | Kafka.Fetch.Response.V13 |
| 23 (Type/Class) | Kafka.ApiVersions.Response.V3, Kafka.ApiVersions.V3 |
| 24 (Data Constructor) | Kafka.ApiVersions.Response.V3 |
| ResponseBodyMalformed | Kafka.Exchange.Error |
| ResponseHeaderMalformed | Kafka.Exchange.Error |
| responseHeaderVersion | |
| 1 (Function) | Kafka.JoinGroup.V9 |
| 2 (Function) | Kafka.Heartbeat.V4 |
| 3 (Function) | Kafka.SyncGroup.V5 |
| 4 (Function) | Kafka.Produce.V9 |
| 5 (Function) | Kafka.OffsetFetch.V8 |
| 6 (Function) | Kafka.Metadata.V12 |
| 7 (Function) | Kafka.ListOffsets.V7 |
| 8 (Function) | Kafka.LeaveGroup.V5 |
| 9 (Function) | Kafka.InitProducerId.V4 |
| 10 (Function) | Kafka.FindCoordinator.V4 |
| 11 (Function) | Kafka.Fetch.V13 |
| 12 (Function) | Kafka.ApiVersions.V3 |
| ResponseHeaderVersionUnsupported | Kafka.Exchange.Error |
| ResponseIncorrectCorrelationId | Kafka.Exchange.Error |
| ResponseLengthNegative | Kafka.Exchange.Error |
| ResponseLengthNotReceived | Kafka.Exchange.Error |
| ResponseLengthTooHigh | Kafka.Exchange.Error |
| ResponseMessageNotReceived | Kafka.Exchange.Error |
| SaslAuthenticate | Kafka.ApiKey |
| SaslAuthenticationFailed | Kafka.ErrorCode |
| SaslHandshake | Kafka.ApiKey |
| SecurityDisabled | Kafka.ErrorCode |
| SessionId | Kafka.Parser.Context |
| singleton | Kafka.Produce.Request.V9 |
| SkipAssignment | Kafka.Parser.Context |
| Snappy | Kafka.RecordBatch.Attributes |
| SnapshotNotFound | Kafka.ErrorCode |
| StaleBrokerEpoch | Kafka.ErrorCode |
| StaleControllerEpoch | Kafka.ErrorCode |
| StopReplica | Kafka.ApiKey |
| Subscription | |
| 1 (Type/Class) | Kafka.Subscription.Request.V1, Kafka.Subscription.Response.V1 |
| 2 (Data Constructor) | Kafka.Subscription.Request.V1, Kafka.Subscription.Response.V1 |
| SyncGroup | Kafka.ApiKey |
| tag | Kafka.TaggedField |
| TagBuffer | Kafka.Parser.Context |
| TaggedField | |
| 1 (Type/Class) | Kafka.TaggedField |
| 2 (Data Constructor) | Kafka.TaggedField |
| TaggedFieldContents | Kafka.Parser.Context |
| TaggedFieldLength | Kafka.Parser.Context |
| TaggedFieldTag | Kafka.Parser.Context |
| ThrottleTimeMilliseconds | Kafka.Parser.Context |
| ThrottlingQuotaExceeded | Kafka.ErrorCode |
| Timestamp | Kafka.Parser.Context |
| TimestampType | Kafka.RecordBatch.Attributes |
| toChunks | |
| 1 (Function) | Kafka.ApiVersions.Request.V3, Kafka.ApiVersions.V3 |
| 2 (Function) | Kafka.Fetch.Request.V13, Kafka.Fetch.V13 |
| 3 (Function) | Kafka.FindCoordinator.Request.V4, Kafka.FindCoordinator.V4 |
| 4 (Function) | Kafka.Heartbeat.Request.V4, Kafka.Heartbeat.V4 |
| 5 (Function) | Kafka.InitProducerId.Request.V4, Kafka.InitProducerId.V4 |
| 6 (Function) | Kafka.JoinGroup.Request.V9, Kafka.JoinGroup.V9 |
| 7 (Function) | Kafka.LeaveGroup.Request.V5, Kafka.LeaveGroup.V5 |
| 8 (Function) | Kafka.ListOffsets.Request.V7, Kafka.ListOffsets.V7 |
| 9 (Function) | Kafka.Message.Request.V2 |
| 10 (Function) | Kafka.Metadata.Request.V12, Kafka.Metadata.V12 |
| 11 (Function) | Kafka.OffsetFetch.Request.V8, Kafka.OffsetFetch.V8 |
| 12 (Function) | Kafka.Record.Request |
| 13 (Function) | Kafka.RecordBatch.Request |
| 14 (Function) | Kafka.Produce.Request.V9, Kafka.Produce.V9 |
| 15 (Function) | Kafka.Subscription.Request.V1 |
| 16 (Function) | Kafka.Assignment.Request.V1 |
| 17 (Function) | Kafka.SyncGroup.Request.V5, Kafka.SyncGroup.V5 |
| toChunksOnto | Kafka.Record.Request |
| Top | Kafka.Parser.Context |
| Topic | |
| 1 (Type/Class) | Kafka.Fetch.Request.V13 |
| 2 (Data Constructor) | Kafka.Fetch.Request.V13 |
| 3 (Type/Class) | Kafka.ListOffsets.Request.V7 |
| 4 (Data Constructor) | Kafka.ListOffsets.Request.V7 |
| 5 (Type/Class) | Kafka.Metadata.Request.V12 |
| 6 (Data Constructor) | Kafka.Metadata.Request.V12 |
| 7 (Type/Class) | Kafka.OffsetFetch.Request.V8 |
| 8 (Data Constructor) | Kafka.OffsetFetch.Request.V8 |
| 9 (Data Constructor) | Kafka.Parser.Context |
| 10 (Type/Class) | Kafka.Produce.Request.V9 |
| 11 (Data Constructor) | Kafka.Produce.Request.V9 |
| 12 (Type/Class) | Kafka.Produce.Response.V9 |
| 13 (Data Constructor) | Kafka.Produce.Response.V9 |
| 14 (Type/Class) | Kafka.OffsetFetch.Response.V8 |
| 15 (Data Constructor) | Kafka.OffsetFetch.Response.V8 |
| 16 (Type/Class) | Kafka.Metadata.Response.V12 |
| 17 (Data Constructor) | Kafka.Metadata.Response.V12 |
| 18 (Type/Class) | Kafka.ListOffsets.Response.V7 |
| 19 (Data Constructor) | Kafka.ListOffsets.Response.V7 |
| 20 (Type/Class) | Kafka.Fetch.Response.V13 |
| 21 (Data Constructor) | Kafka.Fetch.Response.V13 |
| TopicAlreadyExists | Kafka.ErrorCode |
| TopicAuthorizationFailed | Kafka.ErrorCode |
| TopicDeletionDisabled | Kafka.ErrorCode |
| Topics | Kafka.Parser.Context |
| TransactionalIdAuthorizationFailed | Kafka.ErrorCode |
| TransactionalIdNotFound | Kafka.ErrorCode |
| TransactionCoordinatorFenced | Kafka.ErrorCode |
| TxnOffsetCommit | Kafka.ApiKey |
| UnacceptableCredential | Kafka.ErrorCode |
| UnknownLeaderEpoch | Kafka.ErrorCode |
| UnknownMemberId | Kafka.ErrorCode |
| UnknownProducerId | Kafka.ErrorCode |
| UnknownServerError | Kafka.ErrorCode |
| UnknownTopicId | Kafka.ErrorCode |
| UnknownTopicOrPartition | Kafka.ErrorCode |
| UnstableOffsetCommit | Kafka.ErrorCode |
| UnsupportedCompressionType | Kafka.ErrorCode |
| UnsupportedForMessageFormat | Kafka.ErrorCode |
| UnsupportedSaslMechanism | Kafka.ErrorCode |
| UnsupportedVersion | Kafka.ErrorCode |
| UpdateMetadata | Kafka.ApiKey |
| UserData | Kafka.Parser.Context |
| Version | Kafka.Parser.Context |
| WriteTxnMarkers | Kafka.ApiKey |