kafka-interchange-0.2.0.0: Serialization for kafka wire protocol

Index - R

RackKafka.Parser.Context
ReassignmentInProgressKafka.ErrorCode
RebalanceInProgressKafka.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
RecordBatchLeftoverBytesKafka.Parser.Context
RecordBatchLengthKafka.Parser.Context
RecordBatchNotEnoughBytesKafka.Parser.Context
RecordListTooLargeKafka.ErrorCode
RecordsCountKafka.Parser.Context
recordsCount 
1 (Function)Kafka.RecordBatch.Request
2 (Function)Kafka.RecordBatch.Response
recordsPayload 
1 (Function)Kafka.RecordBatch.Request
2 (Function)Kafka.RecordBatch.Response
RenewDelegationTokenKafka.ApiKey
ReplicaNodesKafka.Parser.Context
ReplicaNotAvailableKafka.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
requestKafka.InitProducerId.Request.V4
RequestMessageNotSentKafka.Exchange.Error
RequestTimedOutKafka.ErrorCode
ResourceNotFoundKafka.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
ResponseBodyMalformedKafka.Exchange.Error
ResponseHeaderMalformedKafka.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
ResponseHeaderVersionUnsupportedKafka.Exchange.Error
ResponseIncorrectCorrelationIdKafka.Exchange.Error
ResponseLengthNegativeKafka.Exchange.Error
ResponseLengthNotReceivedKafka.Exchange.Error
ResponseLengthTooHighKafka.Exchange.Error
ResponseMessageNotReceivedKafka.Exchange.Error