kafka-interchange-0.2.0.0: Serialization for kafka wire protocol

Index - $

$sel:acks:RequestKafka.Produce.Request.V9
$sel:allowAutoTopicCreation:RequestKafka.Metadata.Request.V12
$sel:apiKey:ApiKeyVersionSupportKafka.ApiVersions.Response.V3
$sel:apiKey:HeaderKafka.Message.Request.V2
$sel:apiKeys:ResponseKafka.ApiVersions.Response.V3
$sel:apiVersion:HeaderKafka.Message.Request.V2
$sel:assignedPartitions:AssignmentKafka.Assignment.Request.V1, Kafka.Assignment.Response.V1
$sel:assignment:AssignmentKafka.SyncGroup.Request.V5
$sel:assignment:ResponseKafka.SyncGroup.Response.V5
$sel:assignments:RequestKafka.SyncGroup.Request.V5
$sel:attributes:RecordKafka.Record.Response
$sel:authorizedOperations:TopicKafka.Metadata.Response.V12
$sel:baseOffset:PartitionKafka.Produce.Response.V9
$sel:body:RequestKafka.Message.Request.V2
$sel:brokers:ResponseKafka.Metadata.Response.V12
$sel:clientId:HeaderKafka.Message.Request.V2
$sel:clientSoftwareName:RequestKafka.ApiVersions.Request.V3
$sel:clientSoftwareVersion:RequestKafka.ApiVersions.Request.V3
$sel:clusterId:ResponseKafka.Metadata.Response.V12
$sel:committedLeaderEpoch:PartitionKafka.OffsetFetch.Response.V8
$sel:committedOffset:PartitionKafka.OffsetFetch.Response.V8
$sel:controllerId:ResponseKafka.Metadata.Response.V12
$sel:coordinatorKeys:RequestKafka.FindCoordinator.Request.V4
$sel:coordinators:ResponseKafka.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:CoordinatorKafka.FindCoordinator.Response.V4
$sel:errorCode:GroupKafka.OffsetFetch.Response.V8
$sel:errorCode:MemberKafka.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:TopicKafka.Metadata.Response.V12
$sel:errorMessage:CoordinatorKafka.FindCoordinator.Response.V4
$sel:errorMessage:PartitionKafka.Produce.Response.V9
$sel:errors:PartitionKafka.Produce.Response.V9
$sel:fetchOffset:PartitionKafka.Fetch.Request.V13
$sel:generationId:Request 
1 (Function)Kafka.Heartbeat.Request.V4
2 (Function)Kafka.SyncGroup.Request.V5
$sel:generationId:ResponseKafka.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:RequestKafka.OffsetFetch.Request.V8
$sel:groups:ResponseKafka.OffsetFetch.Response.V8
$sel:header:Headed 
1 (Function)Kafka.Header.Response.V0
2 (Function)Kafka.Header.Response.V1
$sel:header:RequestKafka.Message.Request.V2
$sel:headers:Record 
1 (Function)Kafka.Record.Request
2 (Function)Kafka.Record.Response
$sel:highWatermark:PartitionKafka.Fetch.Response.V13
$sel:host:BrokerKafka.Metadata.Response.V12
$sel:host:CoordinatorKafka.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:RequestKafka.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:TopicKafka.Metadata.Response.V12
$sel:isolationLevel:Request 
1 (Function)Kafka.Fetch.Request.V13
2 (Function)Kafka.ListOffsets.Request.V7
$sel:isrNodes:PartitionKafka.Metadata.Response.V12
$sel:key:CoordinatorKafka.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:RequestKafka.FindCoordinator.Request.V4
$sel:lastFetchedEpoch:PartitionKafka.Fetch.Request.V13
$sel:lastStableOffset:PartitionKafka.Fetch.Response.V13
$sel:leader:ResponseKafka.JoinGroup.Response.V9
$sel:leaderEpoch:Partition 
1 (Function)Kafka.Metadata.Response.V12
2 (Function)Kafka.ListOffsets.Response.V7
$sel:leaderId:PartitionKafka.Metadata.Response.V12
$sel:logAppendTimeMilliseconds:PartitionKafka.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:PartitionKafka.Fetch.Request.V13
$sel:maxBytes:RequestKafka.Fetch.Request.V13
$sel:maxVersion:ApiKeyVersionSupportKafka.ApiVersions.Response.V3
$sel:maxWaitMilliseconds:RequestKafka.Fetch.Request.V13
$sel:memberId:AssignmentKafka.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:ResponseKafka.JoinGroup.Response.V9
$sel:members:RequestKafka.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:MemberKafka.JoinGroup.Response.V9
$sel:metadata:PartitionKafka.OffsetFetch.Response.V8
$sel:metadata:ProtocolKafka.JoinGroup.Request.V9
$sel:minBytes:RequestKafka.Fetch.Request.V13
$sel:minVersion:ApiKeyVersionSupportKafka.ApiVersions.Response.V3
$sel:name:ProtocolKafka.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:BrokerKafka.Metadata.Response.V12
$sel:nodeId:CoordinatorKafka.FindCoordinator.Response.V4
$sel:offlineReplicas:PartitionKafka.Metadata.Response.V12
$sel:offset:PartitionKafka.ListOffsets.Response.V7
$sel:offsetDelta:Record 
1 (Function)Kafka.Record.Request
2 (Function)Kafka.Record.Response
$sel:ownedPartitions:SubscriptionKafka.Subscription.Request.V1, Kafka.Subscription.Response.V1
$sel:partitions:OwnershipKafka.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:BrokerKafka.Metadata.Response.V12
$sel:port:CoordinatorKafka.FindCoordinator.Response.V4
$sel:preferredReadReplica:PartitionKafka.Fetch.Response.V13
$sel:producerEpoch:RequestKafka.InitProducerId.Request.V4
$sel:producerEpoch:ResponseKafka.InitProducerId.Response.V4
$sel:producerId:RequestKafka.InitProducerId.Request.V4
$sel:producerId:ResponseKafka.InitProducerId.Response.V4
$sel:protocolName:RequestKafka.SyncGroup.Request.V5
$sel:protocolName:Response 
1 (Function)Kafka.JoinGroup.Response.V9
2 (Function)Kafka.SyncGroup.Response.V5
$sel:protocols:RequestKafka.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:BrokerKafka.Metadata.Response.V12
$sel:rackId:RequestKafka.Fetch.Request.V13
$sel:reason:MemberKafka.LeaveGroup.Request.V5
$sel:reason:RequestKafka.JoinGroup.Request.V9
$sel:rebalanceTimeoutMilliseconds:RequestKafka.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:PartitionKafka.Metadata.Response.V12
$sel:requireStable:RequestKafka.OffsetFetch.Request.V8
$sel:response:Headed 
1 (Function)Kafka.Header.Response.V0
2 (Function)Kafka.Header.Response.V1
$sel:sessionEpoch:RequestKafka.Fetch.Request.V13
$sel:sessionId:RequestKafka.Fetch.Request.V13
$sel:sessionId:ResponseKafka.Fetch.Response.V13
$sel:sessionTimeoutMilliseconds:RequestKafka.JoinGroup.Request.V9
$sel:skipAssignment:ResponseKafka.JoinGroup.Response.V9
$sel:taggedFields:ApiKeyVersionSupportKafka.ApiVersions.Response.V3
$sel:taggedFields:BrokerKafka.Metadata.Response.V12
$sel:taggedFields:CoordinatorKafka.FindCoordinator.Response.V4
$sel:taggedFields:Error 
1 (Function)Kafka.Produce.Response.V9
2 (Function)Kafka.Metadata.Response.V12
$sel:taggedFields:GroupKafka.OffsetFetch.Response.V8
$sel:taggedFields:HeaderKafka.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:RequestKafka.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:OwnershipKafka.Subscription.Request.V1, Kafka.Assignment.Request.V1, Kafka.Subscription.Response.V1, Kafka.Assignment.Response.V1
$sel:topicData:RequestKafka.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:SubscriptionKafka.Subscription.Request.V1, Kafka.Subscription.Response.V1
$sel:transactionalId:Request 
1 (Function)Kafka.InitProducerId.Request.V4
2 (Function)Kafka.Produce.Request.V9
$sel:transactionTimeoutMilliseconds:RequestKafka.InitProducerId.Request.V4
$sel:userData:AssignmentKafka.Assignment.Request.V1, Kafka.Assignment.Response.V1
$sel:userData:SubscriptionKafka.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