public class org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig extends java.lang.Object
{
public final int sessionTimeoutMs;
public final int rebalanceTimeoutMs;
public final int heartbeatIntervalMs;
public final java.lang.String groupId;
public final java.util.Optional groupInstanceId;
public final long retryBackoffMs;
public final boolean leaveGroupOnClose;
public void <init>(org.apache.kafkaesqueesqueesque.common.config.AbstractConfig, org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig$ProtocolType)
{
org.apache.kafkaesqueesqueesque.common.config.AbstractConfig v;
long v;
java.lang.Integer v, v, v, v;
java.lang.Long v;
int v, v, v, v;
java.lang.Boolean v;
java.lang.String v, v;
org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig v;
boolean v;
org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig$ProtocolType v, v, v, v;
java.util.Optional v, v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig;
v := @parameter: org.apache.kafkaesqueesqueesque.common.config.AbstractConfig;
v := @parameter: org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig$ProtocolType;
specialinvoke v.<java.lang.Object: void <init>()>();
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.AbstractConfig: java.lang.Integer getInt(java.lang.String)>("session.timeout.ms");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig: int sessionTimeoutMs> = v;
v = <org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig$ProtocolType: org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig$ProtocolType CONSUMER>;
if v != v goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.AbstractConfig: java.lang.Integer getInt(java.lang.String)>("max.poll.interval.ms");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig: int rebalanceTimeoutMs> = v;
goto label;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.AbstractConfig: java.lang.Integer getInt(java.lang.String)>("rebalance.timeout.ms");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig: int rebalanceTimeoutMs> = v;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.AbstractConfig: java.lang.Integer getInt(java.lang.String)>("heartbeat.interval.ms");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig: int heartbeatIntervalMs> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.AbstractConfig: java.lang.String getString(java.lang.String)>("group.id");
v.<org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig: java.lang.String groupId> = v;
v = <org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig$ProtocolType: org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig$ProtocolType CONSUMER>;
if v != v goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.AbstractConfig: java.lang.String getString(java.lang.String)>("group.instance.id");
if v == null goto label;
staticinvoke <org.apache.kafkaesqueesqueesque.common.requests.JoinGroupRequest: void validateGroupInstanceId(java.lang.String)>(v);
v = staticinvoke <java.util.Optional: java.util.Optional of(java.lang.Object)>(v);
v.<org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig: java.util.Optional groupInstanceId> = v;
goto label;
label:
v = staticinvoke <java.util.Optional: java.util.Optional empty()>();
v.<org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig: java.util.Optional groupInstanceId> = v;
goto label;
label:
v = staticinvoke <java.util.Optional: java.util.Optional empty()>();
v.<org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig: java.util.Optional groupInstanceId> = v;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.AbstractConfig: java.lang.Long getLong(java.lang.String)>("retry.backoff.ms");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v.<org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig: long retryBackoffMs> = v;
v = <org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig$ProtocolType: org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig$ProtocolType CONSUMER>;
if v != v goto label;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.config.AbstractConfig: java.lang.Boolean getBoolean(java.lang.String)>("internal.leave.group.on.close");
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
v.<org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig: boolean leaveGroupOnClose> = v;
goto label;
label:
v.<org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig: boolean leaveGroupOnClose> = 1;
label:
return;
}
public void <init>(int, int, int, java.lang.String, java.util.Optional, long, boolean)
{
long v;
int v, v, v;
java.util.Optional v;
java.lang.String v;
org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig;
v := @parameter: int;
v := @parameter: int;
v := @parameter: int;
v := @parameter: java.lang.String;
v := @parameter: java.util.Optional;
v := @parameter: long;
v := @parameter: boolean;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig: int sessionTimeoutMs> = v;
v.<org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig: int rebalanceTimeoutMs> = v;
v.<org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig: int heartbeatIntervalMs> = v;
v.<org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig: java.lang.String groupId> = v;
v.<org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig: java.util.Optional groupInstanceId> = v;
v.<org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig: long retryBackoffMs> = v;
v.<org.apache.kafkaesqueesqueesque.clients.GroupRebalanceConfig: boolean leaveGroupOnClose> = v;
return;
}
}