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 |