```bash
# Create NDJSON file
cat > documents.ndjson << 'EOF'
{"url":"http://example.com/page1","title":"Page 1","content":"Content here..."}
{"url":"http://example.com/page2","title":"Page 2","content":"More content..."}
EOF

# Import via API
curl -X PUT "http://localhost:8080/api/admin/documents/bulk" \
  -H "Content-Type: application/x-ndjson" \
  -u admin:admin \
  --data-binary @documents.ndjson
```

        String result = normalizer.normalize("test", "content");

        assertNotNull(result);
    }

    @Test
    public void test_normalizeWithLanguage() throws Exception {
        AnalyzerNormalizer normalizer = new AnalyzerNormalizer(runner.client(), suggester.settings());

        String result = normalizer.normalize("test", "content", "en");

        assertNotNull(result);
    }

    @Test

		// Empty Content-Md5 header.
		{mustNewSignedEmptyMD5Request(http.MethodPut, "http://127.0.0.1:9000/", 5, bytes.NewReader([]byte("hello")), t), ErrInvalidDigest},
		// Short Content-Md5 header.
		{mustNewSignedShortMD5Request(http.MethodPut, "http://127.0.0.1:9000/", 5, bytes.NewReader([]byte("hello")), t), ErrInvalidDigest},
		// When request is properly signed, but has bad Content-MD5 header.

        final String content = "Test content for normal file";

        try (FileOutputStream fos = new FileOutputStream(normalFile)) {
            fos.write(content.getBytes("UTF-8"));
        }

        final byte[] result = FileUtil.readBytes(normalFile);
        assertThat(new String(result, "UTF-8"), is(content));
    }

    /**
     * Test readBytes with empty file

                        "responses": {
                            "200": {
                                "description": "Successful Response",
                                "content": {"application/json": {"schema": {}}},
                            }
                        },
                        "security": [{"OAuth2AuthorizationCodeBearer": []}],
                    }
                },

def test_strict_inner_on_lax_app_rejects_no_content_type():
    response = client_nested.post("/outer/strict/items/", content='{"key": "value"}')
    assert response.status_code == 422


def test_default_inner_inherits_lax_from_app():
    response = client_nested.post("/outer/default/items/", content='{"key": "value"}')
    assert response.status_code == 200
    assert response.json() == {"key": "value"}

            final Map<String, Object> doc = new HashMap<>();
            doc.put("title", NAME_PREFIX + i);
            doc.put("url", "http://example.com/bulk/" + i);
            doc.put("content", "This is test content for bulk document " + i);
            doc.put("boost", 1.0f);
            doc.put("role", "Rguest");
            documents.add(doc);
        }

        requestBody.put("documents", documents);

                                "description": "Successful Response",
                                "content": {"application/json": {"schema": {}}},
                            },
                            "422": {
                                "description": "Validation Error",
                                "content": {
                                    "application/json": {
                                        "schema": {

    private static final Logger logger = LogManager.getLogger(GcsClient.class);

    /**
     * The character encoding to use for content. Defaults to UTF-8.
     */
    protected String charset = Constants.UTF_8;

    /**
     * Helper for managing content length validation and limits.
     */
    @Resource
    protected ContentLengthHelper contentLengthHelper;

    /**

    }
  }

  @Test
  fun testSkipUncompressNoContentResponse() {
    val response =
      response("https://httpbin.org/brotli", EMPTY) {
        header("Content-Encoding", "br")
        code(204)
        message("NO CONTENT")
      }

    val same = brotliInterceptor.decompress(response)

    val responseString = same.body.string()
    assertThat(responseString).isEmpty()
  }