Compiled from "DefaultJwtValidator.java" public class org.apache.kafka.common.security.oauthbearer.DefaultJwtValidator implements org.apache.kafka.common.security.oauthbearer.JwtValidator { public org.apache.kafka.common.security.oauthbearer.DefaultJwtValidator(); Code: 0: aload_0 1: invokespecial #16 // Method java/lang/Object."":()V 4: aload_0 5: invokestatic #22 // Method java/util/Optional.empty:()Ljava/util/Optional; 8: putfield #24 // Field verificationKeyResolver:Ljava/util/Optional; 11: return public org.apache.kafka.common.security.oauthbearer.DefaultJwtValidator(org.apache.kafka.common.security.oauthbearer.internals.secured.CloseableVerificationKeyResolver); Code: 0: aload_0 1: invokespecial #16 // Method java/lang/Object."":()V 4: aload_0 5: aload_1 6: invokestatic #31 // Method java/util/Optional.of:(Ljava/lang/Object;)Ljava/util/Optional; 9: putfield #24 // Field verificationKeyResolver:Ljava/util/Optional; 12: return public void configure(java.util.Map, java.lang.String, java.util.List); Code: 0: aload_0 1: getfield #24 // Field verificationKeyResolver:Ljava/util/Optional; 4: invokevirtual #39 // Method java/util/Optional.isPresent:()Z 7: ifeq 34 10: aload_0 11: new #41 // class org/apache/kafka/common/security/oauthbearer/BrokerJwtValidator 14: dup 15: aload_0 16: getfield #24 // Field verificationKeyResolver:Ljava/util/Optional; 19: invokevirtual #45 // Method java/util/Optional.get:()Ljava/lang/Object; 22: checkcast #47 // class org/apache/kafka/common/security/oauthbearer/internals/secured/CloseableVerificationKeyResolver 25: invokespecial #49 // Method org/apache/kafka/common/security/oauthbearer/BrokerJwtValidator."":(Lorg/apache/kafka/common/security/oauthbearer/internals/secured/CloseableVerificationKeyResolver;)V 28: putfield #51 // Field delegate:Lorg/apache/kafka/common/security/oauthbearer/JwtValidator; 31: goto 45 34: aload_0 35: new #53 // class org/apache/kafka/common/security/oauthbearer/ClientJwtValidator 38: dup 39: invokespecial #54 // Method org/apache/kafka/common/security/oauthbearer/ClientJwtValidator."":()V 42: putfield #51 // Field delegate:Lorg/apache/kafka/common/security/oauthbearer/JwtValidator; 45: aload_0 46: getfield #51 // Field delegate:Lorg/apache/kafka/common/security/oauthbearer/JwtValidator; 49: aload_1 50: aload_2 51: aload_3 52: invokeinterface #56, 4 // InterfaceMethod org/apache/kafka/common/security/oauthbearer/JwtValidator.configure:(Ljava/util/Map;Ljava/lang/String;Ljava/util/List;)V 57: return public org.apache.kafka.common.security.oauthbearer.OAuthBearerToken validate(java.lang.String) throws org.apache.kafka.common.security.oauthbearer.JwtValidatorException; Code: 0: aload_0 1: getfield #51 // Field delegate:Lorg/apache/kafka/common/security/oauthbearer/JwtValidator; 4: ifnonnull 17 7: new #70 // class java/lang/IllegalStateException 10: dup 11: ldc #72 // String JWT validator delegate is null; please call configure() first 13: invokespecial #75 // Method java/lang/IllegalStateException."":(Ljava/lang/String;)V 16: athrow 17: aload_0 18: getfield #51 // Field delegate:Lorg/apache/kafka/common/security/oauthbearer/JwtValidator; 21: aload_1 22: invokeinterface #77, 2 // InterfaceMethod org/apache/kafka/common/security/oauthbearer/JwtValidator.validate:(Ljava/lang/String;)Lorg/apache/kafka/common/security/oauthbearer/OAuthBearerToken; 27: areturn public void close() throws java.io.IOException; Code: 0: aload_0 1: getfield #51 // Field delegate:Lorg/apache/kafka/common/security/oauthbearer/JwtValidator; 4: ldc #83 // String JWT validator delegate 6: invokestatic #89 // Method org/apache/kafka/common/utils/Utils.closeQuietly:(Ljava/lang/AutoCloseable;Ljava/lang/String;)V 9: return org.apache.kafka.common.security.oauthbearer.JwtValidator delegate(); Code: 0: aload_0 1: getfield #51 // Field delegate:Lorg/apache/kafka/common/security/oauthbearer/JwtValidator; 4: areturn }