@Test
    @DisplayName("Should parse schema with service definitions")
    @Disabled
    void shouldParseSchemaWithServiceDefinitions() throws Exception {
        // Given
        Path protoPath = Paths.get(TEST_RESOURCES_DIR, "with_service.proto");
        String protoContent = Files.readString(protoPath);
        
        // When
        ProtobufSchema schema = ProtobufSchemaParser.parseSchema(protoContent, Collections.emptyMap());
        
        // Then
        Descriptors.FileDescriptor fileDescriptor = schema.getFileDescriptor();
        DescriptorProtos.FileDescriptorProto fileDescriptorProto = fileDescriptor.toProto();
        
        // Verify service is present
        assertEquals(1, fileDescriptorProto.getServiceCount());
        assertEquals("UserService", fileDescriptorProto.getService(0).getName());
        
        // Verify the service methods
        DescriptorProtos.ServiceDescriptorProto serviceProto = fileDescriptorProto.getService(0);
        assertEquals(8, serviceProto.getMethodCount());
        
        // Verify specific methods and their streaming properties
        Map<String, DescriptorProtos.MethodDescriptorProto> methods = serviceProto.getMethodList().stream()
                .collect(Collectors.toMap(
                        DescriptorProtos.MethodDescriptorProto::getName,
                        method -> method
                ));
        
        // Regular unary method
        assertTrue(methods.containsKey("GetUser"));
        assertFalse(methods.get("GetUser").getClientStreaming());
        assertFalse(methods.get("GetUser").getServerStreaming());
        
        // Server streaming method
        assertTrue(methods.containsKey("StreamUserUpdates"));
        assertFalse(methods.get("StreamUserUpdates").getClientStreaming());
        assertTrue(methods.get("StreamUserUpdates").getServerStreaming());
        
        // Client streaming method
        assertTrue(methods.containsKey("UploadUserData"));
        assertTrue(methods.get("UploadUserData").getClientStreaming());
        assertFalse(methods.get("UploadUserData").getServerStreaming());
        
        // Bidirectional streaming method
        assertTrue(methods.containsKey("ProcessUserBatch"));
        assertTrue(methods.get("ProcessUserBatch").getClientStreaming());
        assertTrue(methods.get("ProcessUserBatch").getServerStreaming());
    }
Tests that verify parsing schema files with Google Well-Known Types and other complex protobuf features.

Note: These tests are currently disabled because they require access to the Well-Known Type definition files
which are not bundled with the test resources. In a real environment, these would be available
through the protobuf library. To make these tests pass, you would need to:  
1. Include the well-known type .proto files in your test resources
2. Make them available to the ProtobufSchemaParser when parsing

Note: The current implementation does not support the `extend` feature.
core/src/test/java/kafka/automq/table/deserializer/proto/parse/ProtobufSchemaWellKnownTypesTest.java