public void processRequest()

in fluss-kafka/src/main/java/com/alibaba/fluss/kafka/KafkaRequestHandler.java [48:147]
99 lines of code
32 McCabe index (conditional complexity)

    public void processRequest(KafkaRequest request) {
        // See kafka.server.KafkaApis#handle
        switch (request.apiKey()) {
            case API_VERSIONS:
                handleApiVersionsRequest(request);
                break;
            case METADATA:
                handleMetadataRequest(request);
                break;
            case PRODUCE:
                handleProducerRequest(request);
                break;
            case FIND_COORDINATOR:
                handleFindCoordinatorRequest(request);
                break;
            case LIST_OFFSETS:
                handleListOffsetRequest(request);
                break;
            case OFFSET_FETCH:
                handleOffsetFetchRequest(request);
                break;
            case OFFSET_COMMIT:
                handleOffsetCommitRequest(request);
                break;
            case FETCH:
                handleFetchRequest(request);
                break;
            case JOIN_GROUP:
                handleJoinGroupRequest(request);
                break;
            case SYNC_GROUP:
                handleSyncGroupRequest(request);
                break;
            case HEARTBEAT:
                handleHeartbeatRequest(request);
                break;
            case LEAVE_GROUP:
                handleLeaveGroupRequest(request);
                break;
            case DESCRIBE_GROUPS:
                handleDescribeGroupsRequest(request);
                break;
            case LIST_GROUPS:
                handleListGroupsRequest(request);
                break;
            case DELETE_GROUPS:
                handleDeleteGroupsRequest(request);
                break;
            case SASL_HANDSHAKE:
                handleSaslHandshakeRequest(request);
                break;
            case SASL_AUTHENTICATE:
                handleSaslAuthenticateRequest(request);
                break;
            case CREATE_TOPICS:
                handleCreateTopicsRequest(request);
                break;
            case INIT_PRODUCER_ID:
                handleInitProducerIdRequest(request);
                break;
            case ADD_PARTITIONS_TO_TXN:
                handleAddPartitionsToTxnRequest(request);
                break;
            case ADD_OFFSETS_TO_TXN:
                handleAddOffsetsToTxnRequest(request);
                break;
            case TXN_OFFSET_COMMIT:
                handleTxnOffsetCommitRequest(request);
                break;
            case END_TXN:
                handleEndTxnRequest(request);
                break;
            case WRITE_TXN_MARKERS:
                handleWriteTxnMarkersRequest(request);
                break;
            case DESCRIBE_CONFIGS:
                handleDescribeConfigsRequest(request);
                break;
            case ALTER_CONFIGS:
                handleAlterConfigsRequest(request);
                break;
            case DELETE_TOPICS:
                handleDeleteTopicsRequest(request);
                break;
            case DELETE_RECORDS:
                handleDeleteRecordsRequest(request);
                break;
            case OFFSET_DELETE:
                handleOffsetDeleteRequest(request);
                break;
            case CREATE_PARTITIONS:
                handleCreatePartitionsRequest(request);
                break;
            case DESCRIBE_CLUSTER:
                handleDescribeClusterRequest(request);
                break;
            default:
                handleUnsupportedRequest(request);
        }
    }