@Test
    public void testValidSaslOauthBearerMechanism() throws Exception {
        String node = "0";
        SecurityProtocol securityProtocol = SecurityProtocol.SASL_SSL;
        configureMechanisms("OAUTHBEARER", Collections.singletonList("OAUTHBEARER"));
        server = createEchoServer(securityProtocol);
        createAndCheckClientConnection(securityProtocol, node);
    }
Tests OAUTHBEARER client and server channels.
clients/src/test/java/org/apache/kafka/common/security/authenticator/SaslAuthenticatorTest.java