public class org.apache.kafkaesqueesque.common.network.ChannelBuilders extends java.lang.Object
{
private void <init>()
{
org.apache.kafkaesqueesque.common.network.ChannelBuilders v;
v := @this: org.apache.kafkaesqueesque.common.network.ChannelBuilders;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static org.apache.kafkaesqueesque.common.network.ChannelBuilder clientChannelBuilder(org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol, org.apache.kafkaesqueesque.common.security.JaasContext$Type, org.apache.kafkaesqueesque.common.config.AbstractConfig, org.apache.kafkaesqueesque.common.network.ListenerName, java.lang.String, org.apache.kafkaesqueesque.common.utils.Time, boolean, org.apache.kafkaesqueesque.common.utils.LogContext)
{
org.apache.kafkaesqueesque.common.security.JaasContext$Type v;
org.apache.kafkaesqueesque.common.network.Mode v;
org.apache.kafkaesqueesque.common.utils.Time v;
org.apache.kafkaesqueesque.common.network.ListenerName v;
java.lang.String v, v, v;
boolean v;
org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol v, v, v;
org.apache.kafkaesqueesque.common.utils.LogContext v;
java.lang.IllegalArgumentException v, v;
org.apache.kafkaesqueesque.common.config.AbstractConfig v;
org.apache.kafkaesqueesque.common.network.ChannelBuilder v;
v := @parameter: org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol;
v := @parameter: org.apache.kafkaesqueesque.common.security.JaasContext$Type;
v := @parameter: org.apache.kafkaesqueesque.common.config.AbstractConfig;
v := @parameter: org.apache.kafkaesqueesque.common.network.ListenerName;
v := @parameter: java.lang.String;
v := @parameter: org.apache.kafkaesqueesque.common.utils.Time;
v := @parameter: boolean;
v := @parameter: org.apache.kafkaesqueesque.common.utils.LogContext;
v = <org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol: org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol SASL_PLAINTEXT>;
if v == v goto label;
v = <org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol: org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol SASL_SSL>;
if v != v goto label;
label:
if v != null goto label;
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("`contextType` must be non-null if `securityProtocol` is `\u0001`");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
if v != null goto label;
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("`clientSaslMechanism` must be non-null in client mode if `securityProtocol` is `\u0001`");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = <org.apache.kafkaesqueesque.common.network.Mode: org.apache.kafkaesqueesque.common.network.Mode CLIENT>;
v = staticinvoke <org.apache.kafkaesqueesque.common.network.ChannelBuilders: org.apache.kafkaesqueesque.common.network.ChannelBuilder create(org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol,org.apache.kafkaesqueesque.common.network.Mode,org.apache.kafkaesqueesque.common.security.JaasContext$Type,org.apache.kafkaesqueesque.common.config.AbstractConfig,org.apache.kafkaesqueesque.common.network.ListenerName,boolean,java.lang.String,boolean,org.apache.kafkaesqueesque.common.security.authenticator.CredentialCache,org.apache.kafkaesqueesque.common.security.token.delegation.internals.DelegationTokenCache,org.apache.kafkaesqueesque.common.utils.Time,org.apache.kafkaesqueesque.common.utils.LogContext)>(v, v, v, v, v, 0, v, v, null, null, v, v);
return v;
}
public static org.apache.kafkaesqueesque.common.network.ChannelBuilder serverChannelBuilder(org.apache.kafkaesqueesque.common.network.ListenerName, boolean, org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol, org.apache.kafkaesqueesque.common.config.AbstractConfig, org.apache.kafkaesqueesque.common.security.authenticator.CredentialCache, org.apache.kafkaesqueesque.common.security.token.delegation.internals.DelegationTokenCache, org.apache.kafkaesqueesque.common.utils.Time, org.apache.kafkaesqueesque.common.utils.LogContext)
{
org.apache.kafkaesqueesque.common.security.JaasContext$Type v;
org.apache.kafkaesqueesque.common.network.Mode v;
org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol v;
org.apache.kafkaesqueesque.common.utils.LogContext v;
org.apache.kafkaesqueesque.common.config.AbstractConfig v;
org.apache.kafkaesqueesque.common.utils.Time v;
org.apache.kafkaesqueesque.common.security.token.delegation.internals.DelegationTokenCache v;
org.apache.kafkaesqueesque.common.network.ListenerName v;
org.apache.kafkaesqueesque.common.network.ChannelBuilder v;
boolean v;
org.apache.kafkaesqueesque.common.security.authenticator.CredentialCache v;
v := @parameter: org.apache.kafkaesqueesque.common.network.ListenerName;
v := @parameter: boolean;
v := @parameter: org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol;
v := @parameter: org.apache.kafkaesqueesque.common.config.AbstractConfig;
v := @parameter: org.apache.kafkaesqueesque.common.security.authenticator.CredentialCache;
v := @parameter: org.apache.kafkaesqueesque.common.security.token.delegation.internals.DelegationTokenCache;
v := @parameter: org.apache.kafkaesqueesque.common.utils.Time;
v := @parameter: org.apache.kafkaesqueesque.common.utils.LogContext;
v = <org.apache.kafkaesqueesque.common.network.Mode: org.apache.kafkaesqueesque.common.network.Mode SERVER>;
v = <org.apache.kafkaesqueesque.common.security.JaasContext$Type: org.apache.kafkaesqueesque.common.security.JaasContext$Type SERVER>;
v = staticinvoke <org.apache.kafkaesqueesque.common.network.ChannelBuilders: org.apache.kafkaesqueesque.common.network.ChannelBuilder create(org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol,org.apache.kafkaesqueesque.common.network.Mode,org.apache.kafkaesqueesque.common.security.JaasContext$Type,org.apache.kafkaesqueesque.common.config.AbstractConfig,org.apache.kafkaesqueesque.common.network.ListenerName,boolean,java.lang.String,boolean,org.apache.kafkaesqueesque.common.security.authenticator.CredentialCache,org.apache.kafkaesqueesque.common.security.token.delegation.internals.DelegationTokenCache,org.apache.kafkaesqueesque.common.utils.Time,org.apache.kafkaesqueesque.common.utils.LogContext)>(v, v, v, v, v, v, null, 1, v, v, v, v);
return v;
}
private static org.apache.kafkaesqueesque.common.network.ChannelBuilder create(org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol, org.apache.kafkaesqueesque.common.network.Mode, org.apache.kafkaesqueesque.common.security.JaasContext$Type, org.apache.kafkaesqueesque.common.config.AbstractConfig, org.apache.kafkaesqueesque.common.network.ListenerName, boolean, java.lang.String, boolean, org.apache.kafkaesqueesque.common.security.authenticator.CredentialCache, org.apache.kafkaesqueesque.common.security.token.delegation.internals.DelegationTokenCache, org.apache.kafkaesqueesque.common.utils.Time, org.apache.kafkaesqueesque.common.utils.LogContext)
{
org.apache.kafkaesqueesque.common.security.JaasContext$Type v, v;
org.apache.kafkaesqueesque.common.network.SaslChannelBuilder v;
org.apache.kafkaesqueesque.common.network.Mode v, v;
org.apache.kafkaesqueesque.common.network.SslChannelBuilder v;
org.apache.kafkaesqueesque.common.utils.Time v;
int[] v;
java.util.Map v, v;
boolean v, v, v;
org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol v;
org.apache.kafkaesqueesque.common.network.PlaintextChannelBuilder v;
org.apache.kafkaesqueesque.common.security.authenticator.CredentialCache v;
java.util.HashMap v;
org.apache.kafkaesqueesque.common.security.JaasContext v, v;
org.apache.kafkaesqueesque.common.network.ListenerName v;
int v, v, v;
java.lang.String v, v;
java.util.Iterator v;
org.apache.kafkaesqueesque.common.utils.LogContext v;
java.lang.IllegalArgumentException v;
org.apache.kafkaesqueesque.common.config.AbstractConfig v;
org.apache.kafkaesqueesque.common.security.token.delegation.internals.DelegationTokenCache v;
java.lang.Object v, v;
org.apache.kafkaesqueesque.common.network.ChannelBuilder v;
v := @parameter: org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol;
v := @parameter: org.apache.kafkaesqueesque.common.network.Mode;
v := @parameter: org.apache.kafkaesqueesque.common.security.JaasContext$Type;
v := @parameter: org.apache.kafkaesqueesque.common.config.AbstractConfig;
v := @parameter: org.apache.kafkaesqueesque.common.network.ListenerName;
v := @parameter: boolean;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v := @parameter: org.apache.kafkaesqueesque.common.security.authenticator.CredentialCache;
v := @parameter: org.apache.kafkaesqueesque.common.security.token.delegation.internals.DelegationTokenCache;
v := @parameter: org.apache.kafkaesqueesque.common.utils.Time;
v := @parameter: org.apache.kafkaesqueesque.common.utils.LogContext;
v = staticinvoke <org.apache.kafkaesqueesque.common.network.ChannelBuilders: java.util.Map channelBuilderConfigs(org.apache.kafkaesqueesque.common.config.AbstractConfig,org.apache.kafkaesqueesque.common.network.ListenerName)>(v, v);
v = <org.apache.kafkaesqueesque.common.network.ChannelBuilders$1: int[] $SwitchMap$org$apache$kafka$common$security$auth$SecurityProtocol>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
default: goto label;
};
label:
staticinvoke <org.apache.kafkaesqueesque.common.network.ChannelBuilders: void requireNonNullMode(org.apache.kafkaesqueesque.common.network.Mode,org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol)>(v, v);
v = new org.apache.kafkaesqueesque.common.network.SslChannelBuilder;
specialinvoke v.<org.apache.kafkaesqueesque.common.network.SslChannelBuilder: void <init>(org.apache.kafkaesqueesque.common.network.Mode,org.apache.kafkaesqueesque.common.network.ListenerName,boolean,org.apache.kafkaesqueesque.common.utils.LogContext)>(v, v, v, v);
v = v;
goto label;
label:
staticinvoke <org.apache.kafkaesqueesque.common.network.ChannelBuilders: void requireNonNullMode(org.apache.kafkaesqueesque.common.network.Mode,org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol)>(v, v);
v = <org.apache.kafkaesqueesque.common.network.Mode: org.apache.kafkaesqueesque.common.network.Mode SERVER>;
if v != v goto label;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("sasl.enabled.mechanisms");
v = new java.util.HashMap;
v = interfaceinvoke v.<java.util.List: int size()>();
specialinvoke v.<java.util.HashMap: void <init>(int)>(v);
v = v;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.security.JaasContext: org.apache.kafkaesqueesque.common.security.JaasContext loadServerContext(org.apache.kafkaesqueesque.common.network.ListenerName,java.lang.String,java.util.Map)>(v, v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = <org.apache.kafkaesqueesque.common.security.JaasContext$Type: org.apache.kafkaesqueesque.common.security.JaasContext$Type CLIENT>;
if v != v goto label;
v = staticinvoke <org.apache.kafkaesqueesque.common.security.JaasContext: org.apache.kafkaesqueesque.common.security.JaasContext loadClientContext(java.util.Map)>(v);
goto label;
label:
v = staticinvoke <org.apache.kafkaesqueesque.common.security.JaasContext: org.apache.kafkaesqueesque.common.security.JaasContext loadServerContext(org.apache.kafkaesqueesque.common.network.ListenerName,java.lang.String,java.util.Map)>(v, v, v);
label:
v = staticinvoke <java.util.Collections: java.util.Map singletonMap(java.lang.Object,java.lang.Object)>(v, v);
label:
v = new org.apache.kafkaesqueesque.common.network.SaslChannelBuilder;
specialinvoke v.<org.apache.kafkaesqueesque.common.network.SaslChannelBuilder: void <init>(org.apache.kafkaesqueesque.common.network.Mode,java.util.Map,org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol,org.apache.kafkaesqueesque.common.network.ListenerName,boolean,java.lang.String,boolean,org.apache.kafkaesqueesque.common.security.authenticator.CredentialCache,org.apache.kafkaesqueesque.common.security.token.delegation.internals.DelegationTokenCache,org.apache.kafkaesqueesque.common.utils.Time,org.apache.kafkaesqueesque.common.utils.LogContext)>(v, v, v, v, v, v, v, v, v, v, v);
v = v;
goto label;
label:
v = new org.apache.kafkaesqueesque.common.network.PlaintextChannelBuilder;
specialinvoke v.<org.apache.kafkaesqueesque.common.network.PlaintextChannelBuilder: void <init>(org.apache.kafkaesqueesque.common.network.ListenerName)>(v);
v = v;
goto label;
label:
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Unexpected securityProtocol \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
interfaceinvoke v.<org.apache.kafkaesqueesque.common.network.ChannelBuilder: void configure(java.util.Map)>(v);
return v;
}
protected static java.util.Map channelBuilderConfigs(org.apache.kafkaesqueesque.common.config.AbstractConfig, org.apache.kafkaesqueesque.common.network.ListenerName)
{
java.util.function.Predicate v, v, v;
java.util.Set v;
java.util.HashMap v;
org.apache.kafkaesqueesque.common.config.AbstractConfig v;
java.util.function.Consumer v;
java.util.stream.Stream v, v, v, v;
java.util.Map v, v;
org.apache.kafkaesqueesque.common.network.ListenerName v;
java.lang.String v;
v := @parameter: org.apache.kafkaesqueesque.common.config.AbstractConfig;
v := @parameter: org.apache.kafkaesqueesque.common.network.ListenerName;
if v != null goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.config.AbstractConfig: java.util.Map values()>();
goto label;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.network.ListenerName: java.lang.String configPrefix()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.config.AbstractConfig: java.util.Map valuesWithPrefixOverride(java.lang.String)>(v);
label:
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.config.AbstractConfig: java.util.Map originals()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.network.ChannelBuilders$lambda_channelBuilderConfigs_0__643: java.util.function.Predicate bootstrap$(java.util.Map)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = staticinvoke <org.apache.kafkaesqueesque.common.network.ChannelBuilders$lambda_channelBuilderConfigs_1__644: java.util.function.Predicate bootstrap$(org.apache.kafkaesqueesque.common.network.ListenerName,java.util.Map)>(v, v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = staticinvoke <org.apache.kafkaesqueesque.common.network.ChannelBuilders$lambda_channelBuilderConfigs_2__645: java.util.function.Predicate bootstrap$(org.apache.kafkaesqueesque.common.network.ListenerName,java.util.Map)>(v, v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = staticinvoke <org.apache.kafkaesqueesque.common.network.ChannelBuilders$lambda_channelBuilderConfigs_3__646: java.util.function.Consumer bootstrap$(java.util.Map)>(v);
interfaceinvoke v.<java.util.stream.Stream: void forEach(java.util.function.Consumer)>(v);
return v;
}
private static void requireNonNullMode(org.apache.kafkaesqueesque.common.network.Mode, org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol)
{
org.apache.kafkaesqueesque.common.network.Mode v;
org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol v;
java.lang.String v;
java.lang.IllegalArgumentException v;
v := @parameter: org.apache.kafkaesqueesque.common.network.Mode;
v := @parameter: org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol;
if v != null goto label;
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.kafkaesqueesque.common.security.auth.SecurityProtocol)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("`mode` must be non-null if `securityProtocol` is `\u0001`");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
private static org.apache.kafkaesqueesque.common.security.auth.PrincipalBuilder createPrincipalBuilder(java.lang.Class, java.util.Map)
{
org.apache.kafkaesqueesque.common.security.auth.DefaultPrincipalBuilder v;
java.util.Map v;
java.lang.Class v;
java.lang.Object v;
v := @parameter: java.lang.Class;
v := @parameter: java.util.Map;
if v != null goto label;
v = new org.apache.kafkaesqueesque.common.security.auth.DefaultPrincipalBuilder;
specialinvoke v.<org.apache.kafkaesqueesque.common.security.auth.DefaultPrincipalBuilder: void <init>()>();
goto label;
label:
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: java.lang.Object newInstance(java.lang.Class)>(v);
label:
interfaceinvoke v.<org.apache.kafkaesqueesque.common.security.auth.PrincipalBuilder: void configure(java.util.Map)>(v);
return v;
}
public static org.apache.kafkaesqueesque.common.security.auth.KafkaPrincipalBuilder createPrincipalBuilder(java.util.Map, org.apache.kafkaesqueesque.common.network.TransportLayer, org.apache.kafkaesqueesque.common.network.Authenticator, org.apache.kafkaesqueesque.common.security.kerberos.KerberosShortNamer, org.apache.kafkaesqueesque.common.security.ssl.SslPrincipalMapper)
{
org.apache.kafkaesqueesque.common.security.kerberos.KerberosShortNamer v;
java.util.Map v;
java.lang.String v, v, v, v;
org.apache.kafkaesqueesque.common.security.authenticator.DefaultKafkaPrincipalBuilder v;
org.apache.kafkaesqueesque.common.security.ssl.SslPrincipalMapper v;
boolean v, v, v;
org.apache.kafkaesqueesque.common.network.Authenticator v;
org.apache.kafkaesqueesque.common.security.auth.PrincipalBuilder v;
org.apache.kafkaesqueesque.common.errors.InvalidConfigurationException v;
org.apache.kafkaesqueesque.common.network.TransportLayer v;
java.lang.Class v, v, v, v;
java.lang.Object v, v;
v := @parameter: java.util.Map;
v := @parameter: org.apache.kafkaesqueesque.common.network.TransportLayer;
v := @parameter: org.apache.kafkaesqueesque.common.network.Authenticator;
v := @parameter: org.apache.kafkaesqueesque.common.security.kerberos.KerberosShortNamer;
v := @parameter: org.apache.kafkaesqueesque.common.security.ssl.SslPrincipalMapper;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("principal.builder.class");
if v == null goto label;
if v != class "Lorg/apache/kafkaesqueesque/common/security/authenticator/DefaultKafkaPrincipalBuilder;" goto label;
label:
v = new org.apache.kafkaesqueesque.common.security.authenticator.DefaultKafkaPrincipalBuilder;
specialinvoke v.<org.apache.kafkaesqueesque.common.security.authenticator.DefaultKafkaPrincipalBuilder: void <init>(org.apache.kafkaesqueesque.common.security.kerberos.KerberosShortNamer,org.apache.kafkaesqueesque.common.security.ssl.SslPrincipalMapper)>(v, v);
goto label;
label:
v = class "Lorg/apache/kafkaesqueesque/common/security/auth/KafkaPrincipalBuilder;";
v = virtualinvoke v.<java.lang.Class: boolean isAssignableFrom(java.lang.Class)>(v);
if v == 0 goto label;
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: java.lang.Object newInstance(java.lang.Class)>(v);
goto label;
label:
v = class "Lorg/apache/kafkaesqueesque/common/security/auth/PrincipalBuilder;";
v = virtualinvoke v.<java.lang.Class: boolean isAssignableFrom(java.lang.Class)>(v);
if v == 0 goto label;
v = staticinvoke <org.apache.kafkaesqueesque.common.network.ChannelBuilders: org.apache.kafkaesqueesque.common.security.auth.PrincipalBuilder createPrincipalBuilder(java.lang.Class,java.util.Map)>(v, v);
v = staticinvoke <org.apache.kafkaesqueesque.common.security.authenticator.DefaultKafkaPrincipalBuilder: org.apache.kafkaesqueesque.common.security.authenticator.DefaultKafkaPrincipalBuilder fromOldPrincipalBuilder(org.apache.kafkaesqueesque.common.network.Authenticator,org.apache.kafkaesqueesque.common.network.TransportLayer,org.apache.kafkaesqueesque.common.security.auth.PrincipalBuilder,org.apache.kafkaesqueesque.common.security.kerberos.KerberosShortNamer)>(v, v, v, v);
goto label;
label:
v = new org.apache.kafkaesqueesque.common.errors.InvalidConfigurationException;
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = class "Lorg/apache/kafkaesqueesque/common/security/auth/PrincipalBuilder;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = class "Lorg/apache/kafkaesqueesque/common/security/auth/KafkaPrincipalBuilder;";
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String)>(v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Type \u is not an instance of \u or \u0001");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.InvalidConfigurationException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v instanceof org.apache.kafkaesqueesque.common.Configurable;
if v == 0 goto label;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.Configurable: void configure(java.util.Map)>(v);
label:
return v;
}
}