in server/src/main/java/org/apache/kafka/network/RequestConvertToJson.java [394:578]
public static JsonNode request(AbstractRequest request) {
switch (request.apiKey()) {
case ADD_OFFSETS_TO_TXN:
return AddOffsetsToTxnRequestDataJsonConverter.write(((AddOffsetsToTxnRequest) request).data(), request.version());
case ADD_PARTITIONS_TO_TXN:
return AddPartitionsToTxnRequestDataJsonConverter.write(((AddPartitionsToTxnRequest) request).data(), request.version());
case ADD_RAFT_VOTER:
return AddRaftVoterRequestDataJsonConverter.write(((AddRaftVoterRequest) request).data(), request.version());
case ALLOCATE_PRODUCER_IDS:
return AllocateProducerIdsRequestDataJsonConverter.write(((AllocateProducerIdsRequest) request).data(), request.version());
case ALTER_CLIENT_QUOTAS:
return AlterClientQuotasRequestDataJsonConverter.write(((AlterClientQuotasRequest) request).data(), request.version());
case ALTER_CONFIGS:
return AlterConfigsRequestDataJsonConverter.write(((AlterConfigsRequest) request).data(), request.version());
case ALTER_PARTITION_REASSIGNMENTS:
return AlterPartitionReassignmentsRequestDataJsonConverter.write(((AlterPartitionReassignmentsRequest) request).data(), request.version());
case ALTER_PARTITION:
return AlterPartitionRequestDataJsonConverter.write(((AlterPartitionRequest) request).data(), request.version());
case ALTER_REPLICA_LOG_DIRS:
return AlterReplicaLogDirsRequestDataJsonConverter.write(((AlterReplicaLogDirsRequest) request).data(), request.version());
case ALTER_SHARE_GROUP_OFFSETS:
return AlterShareGroupOffsetsRequestDataJsonConverter.write(((AlterShareGroupOffsetsRequest) request).data(), request.version());
case ALTER_USER_SCRAM_CREDENTIALS:
return AlterUserScramCredentialsRequestDataJsonConverter.write(((AlterUserScramCredentialsRequest) request).data(), request.version());
case API_VERSIONS:
return ApiVersionsRequestDataJsonConverter.write(((ApiVersionsRequest) request).data(), request.version());
case ASSIGN_REPLICAS_TO_DIRS:
return AssignReplicasToDirsRequestDataJsonConverter.write(((AssignReplicasToDirsRequest) request).data(), request.version());
case BEGIN_QUORUM_EPOCH:
return BeginQuorumEpochRequestDataJsonConverter.write(((BeginQuorumEpochRequest) request).data(), request.version());
case BROKER_HEARTBEAT:
return BrokerHeartbeatRequestDataJsonConverter.write(((BrokerHeartbeatRequest) request).data(), request.version());
case BROKER_REGISTRATION:
return BrokerRegistrationRequestDataJsonConverter.write(((BrokerRegistrationRequest) request).data(), request.version());
case CONSUMER_GROUP_DESCRIBE:
return ConsumerGroupDescribeRequestDataJsonConverter.write(((ConsumerGroupDescribeRequest) request).data(), request.version());
case CONSUMER_GROUP_HEARTBEAT:
return ConsumerGroupHeartbeatRequestDataJsonConverter.write(((ConsumerGroupHeartbeatRequest) request).data(), request.version());
case CONTROLLER_REGISTRATION:
return ControllerRegistrationRequestDataJsonConverter.write(((ControllerRegistrationRequest) request).data(), request.version());
case CREATE_ACLS:
return CreateAclsRequestDataJsonConverter.write(((CreateAclsRequest) request).data(), request.version());
case CREATE_DELEGATION_TOKEN:
return CreateDelegationTokenRequestDataJsonConverter.write(((CreateDelegationTokenRequest) request).data(), request.version());
case CREATE_PARTITIONS:
return CreatePartitionsRequestDataJsonConverter.write(((CreatePartitionsRequest) request).data(), request.version());
case CREATE_TOPICS:
return CreateTopicsRequestDataJsonConverter.write(((CreateTopicsRequest) request).data(), request.version());
case DELETE_ACLS:
return DeleteAclsRequestDataJsonConverter.write(((DeleteAclsRequest) request).data(), request.version());
case DELETE_GROUPS:
return DeleteGroupsRequestDataJsonConverter.write(((DeleteGroupsRequest) request).data(), request.version());
case DELETE_RECORDS:
return DeleteRecordsRequestDataJsonConverter.write(((DeleteRecordsRequest) request).data(), request.version());
case DELETE_SHARE_GROUP_OFFSETS:
return DeleteShareGroupOffsetsRequestDataJsonConverter.write(((DeleteShareGroupOffsetsRequest) request).data(), request.version());
case DELETE_SHARE_GROUP_STATE:
return DeleteShareGroupStateRequestDataJsonConverter.write(((DeleteShareGroupStateRequest) request).data(), request.version());
case DELETE_TOPICS:
return DeleteTopicsRequestDataJsonConverter.write(((DeleteTopicsRequest) request).data(), request.version());
case DESCRIBE_ACLS:
return DescribeAclsRequestDataJsonConverter.write(((DescribeAclsRequest) request).data(), request.version());
case DESCRIBE_CLIENT_QUOTAS:
return DescribeClientQuotasRequestDataJsonConverter.write(((DescribeClientQuotasRequest) request).data(), request.version());
case DESCRIBE_CLUSTER:
return DescribeClusterRequestDataJsonConverter.write(((DescribeClusterRequest) request).data(), request.version());
case DESCRIBE_CONFIGS:
return DescribeConfigsRequestDataJsonConverter.write(((DescribeConfigsRequest) request).data(), request.version());
case DESCRIBE_DELEGATION_TOKEN:
return DescribeDelegationTokenRequestDataJsonConverter.write(((DescribeDelegationTokenRequest) request).data(), request.version());
case DESCRIBE_GROUPS:
return DescribeGroupsRequestDataJsonConverter.write(((DescribeGroupsRequest) request).data(), request.version());
case DESCRIBE_LOG_DIRS:
return DescribeLogDirsRequestDataJsonConverter.write(((DescribeLogDirsRequest) request).data(), request.version());
case DESCRIBE_PRODUCERS:
return DescribeProducersRequestDataJsonConverter.write(((DescribeProducersRequest) request).data(), request.version());
case DESCRIBE_QUORUM:
return DescribeQuorumRequestDataJsonConverter.write(((DescribeQuorumRequest) request).data(), request.version());
case DESCRIBE_SHARE_GROUP_OFFSETS:
return DescribeShareGroupOffsetsRequestDataJsonConverter.write(((DescribeShareGroupOffsetsRequest) request).data(), request.version());
case DESCRIBE_TOPIC_PARTITIONS:
return DescribeTopicPartitionsRequestDataJsonConverter.write(((DescribeTopicPartitionsRequest) request).data(), request.version());
case DESCRIBE_TRANSACTIONS:
return DescribeTransactionsRequestDataJsonConverter.write(((DescribeTransactionsRequest) request).data(), request.version());
case DESCRIBE_USER_SCRAM_CREDENTIALS:
return DescribeUserScramCredentialsRequestDataJsonConverter.write(((DescribeUserScramCredentialsRequest) request).data(), request.version());
case ELECT_LEADERS:
return ElectLeadersRequestDataJsonConverter.write(((ElectLeadersRequest) request).data(), request.version());
case END_QUORUM_EPOCH:
return EndQuorumEpochRequestDataJsonConverter.write(((EndQuorumEpochRequest) request).data(), request.version());
case END_TXN:
return EndTxnRequestDataJsonConverter.write(((EndTxnRequest) request).data(), request.version());
case ENVELOPE:
return EnvelopeRequestDataJsonConverter.write(((EnvelopeRequest) request).data(), request.version());
case EXPIRE_DELEGATION_TOKEN:
return ExpireDelegationTokenRequestDataJsonConverter.write(((ExpireDelegationTokenRequest) request).data(), request.version());
case FETCH:
return FetchRequestDataJsonConverter.write(((FetchRequest) request).data(), request.version());
case FETCH_SNAPSHOT:
return FetchSnapshotRequestDataJsonConverter.write(((FetchSnapshotRequest) request).data(), request.version());
case FIND_COORDINATOR:
return FindCoordinatorRequestDataJsonConverter.write(((FindCoordinatorRequest) request).data(), request.version());
case GET_TELEMETRY_SUBSCRIPTIONS:
return GetTelemetrySubscriptionsRequestDataJsonConverter.write(((GetTelemetrySubscriptionsRequest) request).data(), request.version());
case HEARTBEAT:
return HeartbeatRequestDataJsonConverter.write(((HeartbeatRequest) request).data(), request.version());
case INCREMENTAL_ALTER_CONFIGS:
return IncrementalAlterConfigsRequestDataJsonConverter.write(((IncrementalAlterConfigsRequest) request).data(), request.version());
case INITIALIZE_SHARE_GROUP_STATE:
return InitializeShareGroupStateRequestDataJsonConverter.write(((InitializeShareGroupStateRequest) request).data(), request.version());
case INIT_PRODUCER_ID:
return InitProducerIdRequestDataJsonConverter.write(((InitProducerIdRequest) request).data(), request.version());
case JOIN_GROUP:
return JoinGroupRequestDataJsonConverter.write(((JoinGroupRequest) request).data(), request.version());
case LEAVE_GROUP:
return LeaveGroupRequestDataJsonConverter.write(((LeaveGroupRequest) request).data(), request.version());
case LIST_CLIENT_METRICS_RESOURCES:
return ListClientMetricsResourcesRequestDataJsonConverter.write(((ListClientMetricsResourcesRequest) request).data(), request.version());
case LIST_GROUPS:
return ListGroupsRequestDataJsonConverter.write(((ListGroupsRequest) request).data(), request.version());
case LIST_OFFSETS:
return ListOffsetsRequestDataJsonConverter.write(((ListOffsetsRequest) request).data(), request.version());
case LIST_PARTITION_REASSIGNMENTS:
return ListPartitionReassignmentsRequestDataJsonConverter.write(((ListPartitionReassignmentsRequest) request).data(), request.version());
case LIST_TRANSACTIONS:
return ListTransactionsRequestDataJsonConverter.write(((ListTransactionsRequest) request).data(), request.version());
case METADATA:
return MetadataRequestDataJsonConverter.write(((MetadataRequest) request).data(), request.version());
case OFFSET_COMMIT:
return OffsetCommitRequestDataJsonConverter.write(((OffsetCommitRequest) request).data(), request.version());
case OFFSET_DELETE:
return OffsetDeleteRequestDataJsonConverter.write(((OffsetDeleteRequest) request).data(), request.version());
case OFFSET_FETCH:
return OffsetFetchRequestDataJsonConverter.write(((OffsetFetchRequest) request).data(), request.version());
case OFFSET_FOR_LEADER_EPOCH:
return OffsetForLeaderEpochRequestDataJsonConverter.write(((OffsetsForLeaderEpochRequest) request).data(), request.version());
case PRODUCE:
return ProduceRequestDataJsonConverter.write(((ProduceRequest) request).data(), request.version(), false);
case PUSH_TELEMETRY:
return PushTelemetryRequestDataJsonConverter.write(((PushTelemetryRequest) request).data(), request.version());
case READ_SHARE_GROUP_STATE:
return ReadShareGroupStateRequestDataJsonConverter.write(((ReadShareGroupStateRequest) request).data(), request.version());
case READ_SHARE_GROUP_STATE_SUMMARY:
return ReadShareGroupStateSummaryRequestDataJsonConverter.write(((ReadShareGroupStateSummaryRequest) request).data(), request.version());
case REMOVE_RAFT_VOTER:
return RemoveRaftVoterRequestDataJsonConverter.write(((RemoveRaftVoterRequest) request).data(), request.version());
case RENEW_DELEGATION_TOKEN:
return RenewDelegationTokenRequestDataJsonConverter.write(((RenewDelegationTokenRequest) request).data(), request.version());
case SASL_AUTHENTICATE:
return SaslAuthenticateRequestDataJsonConverter.write(((SaslAuthenticateRequest) request).data(), request.version());
case SASL_HANDSHAKE:
return SaslHandshakeRequestDataJsonConverter.write(((SaslHandshakeRequest) request).data(), request.version());
case SHARE_ACKNOWLEDGE:
return ShareAcknowledgeRequestDataJsonConverter.write(((ShareAcknowledgeRequest) request).data(), request.version());
case SHARE_FETCH:
return ShareFetchRequestDataJsonConverter.write(((ShareFetchRequest) request).data(), request.version());
case SHARE_GROUP_DESCRIBE:
return ShareGroupDescribeRequestDataJsonConverter.write(((ShareGroupDescribeRequest) request).data(), request.version());
case SHARE_GROUP_HEARTBEAT:
return ShareGroupHeartbeatRequestDataJsonConverter.write(((ShareGroupHeartbeatRequest) request).data(), request.version());
case STREAMS_GROUP_DESCRIBE:
return StreamsGroupDescribeRequestDataJsonConverter.write(((StreamsGroupDescribeRequest) request).data(), request.version());
case STREAMS_GROUP_HEARTBEAT:
return StreamsGroupHeartbeatRequestDataJsonConverter.write(((StreamsGroupHeartbeatRequest) request).data(), request.version());
case SYNC_GROUP:
return SyncGroupRequestDataJsonConverter.write(((SyncGroupRequest) request).data(), request.version());
case TXN_OFFSET_COMMIT:
return TxnOffsetCommitRequestDataJsonConverter.write(((TxnOffsetCommitRequest) request).data(), request.version());
case UNREGISTER_BROKER:
return UnregisterBrokerRequestDataJsonConverter.write(((UnregisterBrokerRequest) request).data(), request.version());
case UPDATE_FEATURES:
return UpdateFeaturesRequestDataJsonConverter.write(((UpdateFeaturesRequest) request).data(), request.version());
case UPDATE_RAFT_VOTER:
return UpdateRaftVoterRequestDataJsonConverter.write(((UpdateRaftVoterRequest) request).data(), request.version());
case VOTE:
return VoteRequestDataJsonConverter.write(((VoteRequest) request).data(), request.version());
case WRITE_SHARE_GROUP_STATE:
return WriteShareGroupStateRequestDataJsonConverter.write(((WriteShareGroupStateRequest) request).data(), request.version());
case WRITE_TXN_MARKERS:
return WriteTxnMarkersRequestDataJsonConverter.write(((WriteTxnMarkersRequest) request).data(), request.version());
default:
throw new IllegalStateException("ApiKey " + request.apiKey() + " is not currently handled in `request`, the " +
"code should be updated to do so.");
}
}