showuon commented on code in PR #18576: URL: https://github.com/apache/kafka/pull/18576#discussion_r1922331268
########## clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/AccessTokenRetrieverFactoryTest.java: ########## @@ -55,21 +62,33 @@ public void testConfigureRefreshingFileAccessTokenRetriever() throws Exception { @Test public void testConfigureRefreshingFileAccessTokenRetrieverWithInvalidDirectory() { // Should fail because the parent path doesn't exist. - Map<String, ?> configs = getSaslConfigs(SASL_OAUTHBEARER_TOKEN_ENDPOINT_URL, new File("/tmp/this-directory-does-not-exist/foo.json").toURI().toString()); + String file = new File("/tmp/this-directory-does-not-exist/foo.json").toURI().toString(); + Map<String, ?> configs = getSaslConfigs(SASL_OAUTHBEARER_TOKEN_ENDPOINT_URL, file); Map<String, Object> jaasConfig = Collections.emptyMap(); assertThrowsWithMessage(ConfigException.class, () -> AccessTokenRetrieverFactory.create(configs, jaasConfig), "that doesn't exist"); } @Test public void testConfigureRefreshingFileAccessTokenRetrieverWithInvalidFile() throws Exception { - // Should fail because the while the parent path exists, the file itself doesn't. + // Should fail because while the parent path exists, the file itself doesn't. File tmpDir = createTempDir("this-directory-does-exist"); File accessTokenFile = new File(tmpDir, "this-file-does-not-exist.json"); Map<String, ?> configs = getSaslConfigs(SASL_OAUTHBEARER_TOKEN_ENDPOINT_URL, accessTokenFile.toURI().toString()); Map<String, Object> jaasConfig = Collections.emptyMap(); assertThrowsWithMessage(ConfigException.class, () -> AccessTokenRetrieverFactory.create(configs, jaasConfig), "that doesn't exist"); } + @Test + public void testSaslOauthbearerTokenEndpointUrlIsNotAllowed() throws Exception { + // Should fail because while the parent path exists, the file itself doesn't. Review Comment: Ah, nice catch! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org