in clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java [114:298]
public static AbstractResponse parseResponse(ApiKeys apiKey, Readable readable, short version) {
switch (apiKey) {
case PRODUCE:
return ProduceResponse.parse(readable, version);
case FETCH:
return FetchResponse.parse(readable, version);
case LIST_OFFSETS:
return ListOffsetsResponse.parse(readable, version);
case METADATA:
return MetadataResponse.parse(readable, version);
case OFFSET_COMMIT:
return OffsetCommitResponse.parse(readable, version);
case OFFSET_FETCH:
return OffsetFetchResponse.parse(readable, version);
case FIND_COORDINATOR:
return FindCoordinatorResponse.parse(readable, version);
case JOIN_GROUP:
return JoinGroupResponse.parse(readable, version);
case HEARTBEAT:
return HeartbeatResponse.parse(readable, version);
case LEAVE_GROUP:
return LeaveGroupResponse.parse(readable, version);
case SYNC_GROUP:
return SyncGroupResponse.parse(readable, version);
case DESCRIBE_GROUPS:
return DescribeGroupsResponse.parse(readable, version);
case LIST_GROUPS:
return ListGroupsResponse.parse(readable, version);
case SASL_HANDSHAKE:
return SaslHandshakeResponse.parse(readable, version);
case API_VERSIONS:
return ApiVersionsResponse.parse(readable, version);
case CREATE_TOPICS:
return CreateTopicsResponse.parse(readable, version);
case DELETE_TOPICS:
return DeleteTopicsResponse.parse(readable, version);
case DELETE_RECORDS:
return DeleteRecordsResponse.parse(readable, version);
case INIT_PRODUCER_ID:
return InitProducerIdResponse.parse(readable, version);
case OFFSET_FOR_LEADER_EPOCH:
return OffsetsForLeaderEpochResponse.parse(readable, version);
case ADD_PARTITIONS_TO_TXN:
return AddPartitionsToTxnResponse.parse(readable, version);
case ADD_OFFSETS_TO_TXN:
return AddOffsetsToTxnResponse.parse(readable, version);
case END_TXN:
return EndTxnResponse.parse(readable, version);
case WRITE_TXN_MARKERS:
return WriteTxnMarkersResponse.parse(readable, version);
case TXN_OFFSET_COMMIT:
return TxnOffsetCommitResponse.parse(readable, version);
case DESCRIBE_ACLS:
return DescribeAclsResponse.parse(readable, version);
case CREATE_ACLS:
return CreateAclsResponse.parse(readable, version);
case DELETE_ACLS:
return DeleteAclsResponse.parse(readable, version);
case DESCRIBE_CONFIGS:
return DescribeConfigsResponse.parse(readable, version);
case ALTER_CONFIGS:
return AlterConfigsResponse.parse(readable, version);
case ALTER_REPLICA_LOG_DIRS:
return AlterReplicaLogDirsResponse.parse(readable, version);
case DESCRIBE_LOG_DIRS:
return DescribeLogDirsResponse.parse(readable, version);
case SASL_AUTHENTICATE:
return SaslAuthenticateResponse.parse(readable, version);
case CREATE_PARTITIONS:
return CreatePartitionsResponse.parse(readable, version);
case CREATE_DELEGATION_TOKEN:
return CreateDelegationTokenResponse.parse(readable, version);
case RENEW_DELEGATION_TOKEN:
return RenewDelegationTokenResponse.parse(readable, version);
case EXPIRE_DELEGATION_TOKEN:
return ExpireDelegationTokenResponse.parse(readable, version);
case DESCRIBE_DELEGATION_TOKEN:
return DescribeDelegationTokenResponse.parse(readable, version);
case DELETE_GROUPS:
return DeleteGroupsResponse.parse(readable, version);
case ELECT_LEADERS:
return ElectLeadersResponse.parse(readable, version);
case INCREMENTAL_ALTER_CONFIGS:
return IncrementalAlterConfigsResponse.parse(readable, version);
case ALTER_PARTITION_REASSIGNMENTS:
return AlterPartitionReassignmentsResponse.parse(readable, version);
case LIST_PARTITION_REASSIGNMENTS:
return ListPartitionReassignmentsResponse.parse(readable, version);
case OFFSET_DELETE:
return OffsetDeleteResponse.parse(readable, version);
case DESCRIBE_CLIENT_QUOTAS:
return DescribeClientQuotasResponse.parse(readable, version);
case ALTER_CLIENT_QUOTAS:
return AlterClientQuotasResponse.parse(readable, version);
case DESCRIBE_USER_SCRAM_CREDENTIALS:
return DescribeUserScramCredentialsResponse.parse(readable, version);
case ALTER_USER_SCRAM_CREDENTIALS:
return AlterUserScramCredentialsResponse.parse(readable, version);
case VOTE:
return VoteResponse.parse(readable, version);
case BEGIN_QUORUM_EPOCH:
return BeginQuorumEpochResponse.parse(readable, version);
case END_QUORUM_EPOCH:
return EndQuorumEpochResponse.parse(readable, version);
case DESCRIBE_QUORUM:
return DescribeQuorumResponse.parse(readable, version);
case ALTER_PARTITION:
return AlterPartitionResponse.parse(readable, version);
case UPDATE_FEATURES:
return UpdateFeaturesResponse.parse(readable, version);
case ENVELOPE:
return EnvelopeResponse.parse(readable, version);
case FETCH_SNAPSHOT:
return FetchSnapshotResponse.parse(readable, version);
case DESCRIBE_CLUSTER:
return DescribeClusterResponse.parse(readable, version);
case DESCRIBE_PRODUCERS:
return DescribeProducersResponse.parse(readable, version);
case BROKER_REGISTRATION:
return BrokerRegistrationResponse.parse(readable, version);
case BROKER_HEARTBEAT:
return BrokerHeartbeatResponse.parse(readable, version);
case UNREGISTER_BROKER:
return UnregisterBrokerResponse.parse(readable, version);
case DESCRIBE_TRANSACTIONS:
return DescribeTransactionsResponse.parse(readable, version);
case LIST_TRANSACTIONS:
return ListTransactionsResponse.parse(readable, version);
case ALLOCATE_PRODUCER_IDS:
return AllocateProducerIdsResponse.parse(readable, version);
case CONSUMER_GROUP_HEARTBEAT:
return ConsumerGroupHeartbeatResponse.parse(readable, version);
case CONSUMER_GROUP_DESCRIBE:
return ConsumerGroupDescribeResponse.parse(readable, version);
case CONTROLLER_REGISTRATION:
return ControllerRegistrationResponse.parse(readable, version);
case GET_TELEMETRY_SUBSCRIPTIONS:
return GetTelemetrySubscriptionsResponse.parse(readable, version);
case PUSH_TELEMETRY:
return PushTelemetryResponse.parse(readable, version);
case ASSIGN_REPLICAS_TO_DIRS:
return AssignReplicasToDirsResponse.parse(readable, version);
case LIST_CLIENT_METRICS_RESOURCES:
return ListClientMetricsResourcesResponse.parse(readable, version);
case DESCRIBE_TOPIC_PARTITIONS:
return DescribeTopicPartitionsResponse.parse(readable, version);
case SHARE_GROUP_HEARTBEAT:
return ShareGroupHeartbeatResponse.parse(readable, version);
case SHARE_GROUP_DESCRIBE:
return ShareGroupDescribeResponse.parse(readable, version);
case SHARE_FETCH:
return ShareFetchResponse.parse(readable, version);
case SHARE_ACKNOWLEDGE:
return ShareAcknowledgeResponse.parse(readable, version);
case ADD_RAFT_VOTER:
return AddRaftVoterResponse.parse(readable, version);
case REMOVE_RAFT_VOTER:
return RemoveRaftVoterResponse.parse(readable, version);
case UPDATE_RAFT_VOTER:
return UpdateRaftVoterResponse.parse(readable, version);
case INITIALIZE_SHARE_GROUP_STATE:
return InitializeShareGroupStateResponse.parse(readable, version);
case READ_SHARE_GROUP_STATE:
return ReadShareGroupStateResponse.parse(readable, version);
case WRITE_SHARE_GROUP_STATE:
return WriteShareGroupStateResponse.parse(readable, version);
case DELETE_SHARE_GROUP_STATE:
return DeleteShareGroupStateResponse.parse(readable, version);
case READ_SHARE_GROUP_STATE_SUMMARY:
return ReadShareGroupStateSummaryResponse.parse(readable, version);
case STREAMS_GROUP_HEARTBEAT:
return StreamsGroupHeartbeatResponse.parse(readable, version);
case STREAMS_GROUP_DESCRIBE:
return StreamsGroupDescribeResponse.parse(readable, version);
case DESCRIBE_SHARE_GROUP_OFFSETS:
return DescribeShareGroupOffsetsResponse.parse(readable, version);
case ALTER_SHARE_GROUP_OFFSETS:
return AlterShareGroupOffsetsResponse.parse(readable, version);
case DELETE_SHARE_GROUP_OFFSETS:
return DeleteShareGroupOffsetsResponse.parse(readable, version);
default:
throw new AssertionError(String.format("ApiKey %s is not currently handled in `parseResponse`, the " +
"code should be updated to do so.", apiKey));
}
}