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 |