public abstract class org.apache.kafkaesque.common.requests.AbstractResponse extends java.lang.Object implements org.apache.kafkaesque.common.requests.AbstractRequestResponse
{
public static final int DEFAULT_THROTTLE_TIME;
public void <init>()
{
org.apache.kafkaesque.common.requests.AbstractResponse v;
v := @this: org.apache.kafkaesque.common.requests.AbstractResponse;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
protected org.apache.kafkaesque.common.network.Send toSend(java.lang.String, org.apache.kafkaesque.common.requests.ResponseHeader, short)
{
org.apache.kafkaesque.common.requests.ResponseHeader v;
java.nio.ByteBuffer v;
org.apache.kafkaesque.common.protocol.types.Struct v, v;
short v;
org.apache.kafkaesque.common.network.NetworkSend v;
java.lang.String v;
org.apache.kafkaesque.common.requests.AbstractResponse v;
v := @this: org.apache.kafkaesque.common.requests.AbstractResponse;
v := @parameter: java.lang.String;
v := @parameter: org.apache.kafkaesque.common.requests.ResponseHeader;
v := @parameter: short;
v = new org.apache.kafkaesque.common.network.NetworkSend;
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.ResponseHeader: org.apache.kafkaesque.common.protocol.types.Struct toStruct()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.AbstractResponse: org.apache.kafkaesque.common.protocol.types.Struct toStruct(short)>(v);
v = staticinvoke <org.apache.kafkaesque.common.requests.RequestUtils: java.nio.ByteBuffer serialize(org.apache.kafkaesque.common.protocol.types.Struct,org.apache.kafkaesque.common.protocol.types.Struct)>(v, v);
specialinvoke v.<org.apache.kafkaesque.common.network.NetworkSend: void <init>(java.lang.String,java.nio.ByteBuffer)>(v, v);
return v;
}
public java.nio.ByteBuffer serialize(short, org.apache.kafkaesque.common.requests.ResponseHeader)
{
org.apache.kafkaesque.common.protocol.types.Struct v, v;
short v;
org.apache.kafkaesque.common.requests.AbstractResponse v;
org.apache.kafkaesque.common.requests.ResponseHeader v;
java.nio.ByteBuffer v;
v := @this: org.apache.kafkaesque.common.requests.AbstractResponse;
v := @parameter: short;
v := @parameter: org.apache.kafkaesque.common.requests.ResponseHeader;
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.ResponseHeader: org.apache.kafkaesque.common.protocol.types.Struct toStruct()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.AbstractResponse: org.apache.kafkaesque.common.protocol.types.Struct toStruct(short)>(v);
v = staticinvoke <org.apache.kafkaesque.common.requests.RequestUtils: java.nio.ByteBuffer serialize(org.apache.kafkaesque.common.protocol.types.Struct,org.apache.kafkaesque.common.protocol.types.Struct)>(v, v);
return v;
}
public java.nio.ByteBuffer serialize(org.apache.kafkaesque.common.protocol.ApiKeys, short, int)
{
org.apache.kafkaesque.common.protocol.ApiKeys v;
org.apache.kafkaesque.common.requests.ResponseHeader v;
java.nio.ByteBuffer v;
org.apache.kafkaesque.common.protocol.types.Struct v, v;
short v, v;
int v;
org.apache.kafkaesque.common.requests.AbstractResponse v;
v := @this: org.apache.kafkaesque.common.requests.AbstractResponse;
v := @parameter: org.apache.kafkaesque.common.protocol.ApiKeys;
v := @parameter: short;
v := @parameter: int;
v = new org.apache.kafkaesque.common.requests.ResponseHeader;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.ApiKeys: short responseHeaderVersion(short)>(v);
specialinvoke v.<org.apache.kafkaesque.common.requests.ResponseHeader: void <init>(int,short)>(v, v);
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.ResponseHeader: org.apache.kafkaesque.common.protocol.types.Struct toStruct()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.AbstractResponse: org.apache.kafkaesque.common.protocol.types.Struct toStruct(short)>(v);
v = staticinvoke <org.apache.kafkaesque.common.requests.RequestUtils: java.nio.ByteBuffer serialize(org.apache.kafkaesque.common.protocol.types.Struct,org.apache.kafkaesque.common.protocol.types.Struct)>(v, v);
return v;
}
public abstract java.util.Map errorCounts();
protected java.util.Map errorCounts(org.apache.kafkaesque.common.protocol.Errors)
{
org.apache.kafkaesque.common.protocol.Errors v;
java.util.Map v;
org.apache.kafkaesque.common.requests.AbstractResponse v;
java.lang.Integer v;
v := @this: org.apache.kafkaesque.common.requests.AbstractResponse;
v := @parameter: org.apache.kafkaesque.common.protocol.Errors;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
v = staticinvoke <java.util.Collections: java.util.Map singletonMap(java.lang.Object,java.lang.Object)>(v, v);
return v;
}
protected java.util.Map errorCounts(java.util.Collection)
{
java.util.Iterator v;
java.util.Collection v;
java.lang.Object v;
java.util.HashMap v;
org.apache.kafkaesque.common.requests.AbstractResponse v;
boolean v;
v := @this: org.apache.kafkaesque.common.requests.AbstractResponse;
v := @parameter: java.util.Collection;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = interfaceinvoke v.<java.util.Collection: 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()>();
virtualinvoke v.<org.apache.kafkaesque.common.requests.AbstractResponse: void updateErrorCounts(java.util.Map,org.apache.kafkaesque.common.protocol.Errors)>(v, v);
goto label;
label:
return v;
}
protected java.util.Map apiErrorCounts(java.util.Map)
{
org.apache.kafkaesque.common.protocol.Errors v;
java.util.Iterator v;
java.util.Collection v;
java.util.HashMap v;
java.util.Map v;
java.lang.Object v;
org.apache.kafkaesque.common.requests.AbstractResponse v;
boolean v;
v := @this: org.apache.kafkaesque.common.requests.AbstractResponse;
v := @parameter: java.util.Map;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: 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 = virtualinvoke v.<org.apache.kafkaesque.common.requests.ApiError: org.apache.kafkaesque.common.protocol.Errors error()>();
virtualinvoke v.<org.apache.kafkaesque.common.requests.AbstractResponse: void updateErrorCounts(java.util.Map,org.apache.kafkaesque.common.protocol.Errors)>(v, v);
goto label;
label:
return v;
}
protected void updateErrorCounts(java.util.Map, org.apache.kafkaesque.common.protocol.Errors)
{
org.apache.kafkaesque.common.protocol.Errors v;
java.util.Map v;
int v, v;
java.lang.Object v;
org.apache.kafkaesque.common.requests.AbstractResponse v;
java.lang.Integer v;
v := @this: org.apache.kafkaesque.common.requests.AbstractResponse;
v := @parameter: java.util.Map;
v := @parameter: org.apache.kafkaesque.common.protocol.Errors;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = 1;
goto label;
label:
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = v + 1;
label:
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
return;
}
protected abstract org.apache.kafkaesque.common.protocol.types.Struct toStruct(short);
public static org.apache.kafkaesque.common.requests.AbstractResponse parseResponse(org.apache.kafkaesque.common.protocol.ApiKeys, org.apache.kafkaesque.common.protocol.types.Struct, short)
{
org.apache.kafkaesque.common.requests.TxnOffsetCommitResponse v;
org.apache.kafkaesque.common.requests.UpdateMetadataResponse v;
org.apache.kafkaesque.common.requests.DescribeDelegationTokenResponse v;
org.apache.kafkaesque.common.protocol.ApiKeys v;
org.apache.kafkaesque.common.requests.EndTxnResponse v;
org.apache.kafkaesque.common.requests.CreateTopicsResponse v;
org.apache.kafkaesque.common.requests.DeleteGroupsResponse v;
org.apache.kafkaesque.common.requests.LeaderAndIsrResponse v;
org.apache.kafkaesque.common.requests.ApiVersionsResponse v;
org.apache.kafkaesque.common.requests.HeartbeatResponse v;
org.apache.kafkaesque.common.requests.OffsetFetchResponse v;
org.apache.kafkaesque.common.requests.ListPartitionReassignmentsResponse v;
int[] v;
org.apache.kafkaesque.common.requests.AlterConfigsResponse v;
org.apache.kafkaesque.common.requests.OffsetsForLeaderEpochResponse v;
org.apache.kafkaesque.common.requests.ExpireDelegationTokenResponse v;
org.apache.kafkaesque.common.requests.FindCoordinatorResponse v;
org.apache.kafkaesque.common.requests.SaslHandshakeResponse v;
org.apache.kafkaesque.common.requests.FetchResponse v;
org.apache.kafkaesque.common.requests.DeleteAclsResponse v;
org.apache.kafkaesque.common.requests.LeaveGroupResponse v;
org.apache.kafkaesque.common.requests.DescribeConfigsResponse v;
org.apache.kafkaesque.common.requests.ListGroupsResponse v;
org.apache.kafkaesque.common.requests.SyncGroupResponse v;
org.apache.kafkaesque.common.requests.CreatePartitionsResponse v;
org.apache.kafkaesque.common.requests.CreateDelegationTokenResponse v;
org.apache.kafkaesque.common.requests.MetadataResponse v;
org.apache.kafkaesque.common.requests.InitProducerIdResponse v;
org.apache.kafkaesque.common.requests.DescribeGroupsResponse v;
org.apache.kafkaesque.common.requests.AlterPartitionReassignmentsResponse v;
org.apache.kafkaesque.common.requests.DeleteRecordsResponse v;
org.apache.kafkaesque.common.requests.ElectLeadersResponse v;
org.apache.kafkaesque.common.requests.JoinGroupResponse v;
org.apache.kafkaesque.common.requests.ProduceResponse v;
java.lang.Object[] v;
org.apache.kafkaesque.common.requests.AddPartitionsToTxnResponse v;
org.apache.kafkaesque.common.requests.RenewDelegationTokenResponse v;
org.apache.kafkaesque.common.requests.ListOffsetResponse v;
java.lang.AssertionError v;
org.apache.kafkaesque.common.requests.CreateAclsResponse v;
org.apache.kafkaesque.common.requests.StopReplicaResponse v;
org.apache.kafkaesque.common.requests.AlterReplicaLogDirsResponse v;
short v;
int v, v;
java.lang.String v;
org.apache.kafkaesque.common.requests.ControlledShutdownResponse v;
org.apache.kafkaesque.common.requests.DescribeLogDirsResponse v;
org.apache.kafkaesque.common.requests.OffsetDeleteResponse v;
org.apache.kafkaesque.common.requests.IncrementalAlterConfigsResponse v;
org.apache.kafkaesque.common.requests.DescribeAclsResponse v;
org.apache.kafkaesque.common.requests.SaslAuthenticateResponse v;
org.apache.kafkaesque.common.protocol.types.Struct v;
org.apache.kafkaesque.common.requests.AddOffsetsToTxnResponse v;
org.apache.kafkaesque.common.requests.DeleteTopicsResponse v;
org.apache.kafkaesque.common.requests.OffsetCommitResponse v;
org.apache.kafkaesque.common.requests.WriteTxnMarkersResponse v;
v := @parameter: org.apache.kafkaesque.common.protocol.ApiKeys;
v := @parameter: org.apache.kafkaesque.common.protocol.types.Struct;
v := @parameter: short;
v = <org.apache.kafkaesque.common.requests.AbstractResponse$1: int[] $SwitchMap$org$apache$kafka$common$protocol$ApiKeys>;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.ApiKeys: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
case 5: goto label;
case 6: goto label;
case 7: goto label;
case 8: goto label;
case 9: goto label;
case 10: goto label;
case 11: goto label;
case 12: goto label;
case 13: goto label;
case 14: goto label;
case 15: goto label;
case 16: goto label;
case 17: goto label;
case 18: goto label;
case 19: goto label;
case 20: goto label;
case 21: goto label;
case 22: goto label;
case 23: goto label;
case 24: goto label;
case 25: goto label;
case 26: goto label;
case 27: goto label;
case 28: goto label;
case 29: goto label;
case 30: goto label;
case 31: goto label;
case 32: goto label;
case 33: goto label;
case 34: goto label;
case 35: goto label;
case 36: goto label;
case 37: goto label;
case 38: goto label;
case 39: goto label;
case 40: goto label;
case 41: goto label;
case 42: goto label;
case 43: goto label;
case 44: goto label;
case 45: goto label;
case 46: goto label;
case 47: goto label;
case 48: goto label;
default: goto label;
};
label:
v = new org.apache.kafkaesque.common.requests.ProduceResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.ProduceResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct)>(v);
return v;
label:
v = staticinvoke <org.apache.kafkaesque.common.requests.FetchResponse: org.apache.kafkaesque.common.requests.FetchResponse parse(org.apache.kafkaesque.common.protocol.types.Struct)>(v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.ListOffsetResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.ListOffsetResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct)>(v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.MetadataResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.MetadataResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.OffsetCommitResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.OffsetCommitResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.OffsetFetchResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.OffsetFetchResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.FindCoordinatorResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.FindCoordinatorResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.JoinGroupResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.JoinGroupResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.HeartbeatResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.HeartbeatResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.LeaveGroupResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.LeaveGroupResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.SyncGroupResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.SyncGroupResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.StopReplicaResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.StopReplicaResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.ControlledShutdownResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.ControlledShutdownResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.UpdateMetadataResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.UpdateMetadataResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.LeaderAndIsrResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.LeaderAndIsrResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.DescribeGroupsResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.DescribeGroupsResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.ListGroupsResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.ListGroupsResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.SaslHandshakeResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.SaslHandshakeResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = staticinvoke <org.apache.kafkaesque.common.requests.ApiVersionsResponse: org.apache.kafkaesque.common.requests.ApiVersionsResponse fromStruct(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.CreateTopicsResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.CreateTopicsResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.DeleteTopicsResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.DeleteTopicsResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.DeleteRecordsResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.DeleteRecordsResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct)>(v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.InitProducerIdResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.InitProducerIdResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.OffsetsForLeaderEpochResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.OffsetsForLeaderEpochResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct)>(v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.AddPartitionsToTxnResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.AddPartitionsToTxnResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct)>(v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.AddOffsetsToTxnResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.AddOffsetsToTxnResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct)>(v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.EndTxnResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.EndTxnResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.WriteTxnMarkersResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.WriteTxnMarkersResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct)>(v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.TxnOffsetCommitResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.TxnOffsetCommitResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.DescribeAclsResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.DescribeAclsResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.CreateAclsResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.CreateAclsResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.DeleteAclsResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.DeleteAclsResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.DescribeConfigsResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.DescribeConfigsResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct)>(v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.AlterConfigsResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.AlterConfigsResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct)>(v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.AlterReplicaLogDirsResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.AlterReplicaLogDirsResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct)>(v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.DescribeLogDirsResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.DescribeLogDirsResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct)>(v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.SaslAuthenticateResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.SaslAuthenticateResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.CreatePartitionsResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.CreatePartitionsResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.CreateDelegationTokenResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.CreateDelegationTokenResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.RenewDelegationTokenResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.RenewDelegationTokenResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.ExpireDelegationTokenResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.ExpireDelegationTokenResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.DescribeDelegationTokenResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.DescribeDelegationTokenResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.DeleteGroupsResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.DeleteGroupsResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.ElectLeadersResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.ElectLeadersResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.IncrementalAlterConfigsResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.IncrementalAlterConfigsResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.AlterPartitionReassignmentsResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.AlterPartitionReassignmentsResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.ListPartitionReassignmentsResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.ListPartitionReassignmentsResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new org.apache.kafkaesque.common.requests.OffsetDeleteResponse;
specialinvoke v.<org.apache.kafkaesque.common.requests.OffsetDeleteResponse: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return v;
label:
v = new java.lang.AssertionError;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("ApiKey %s is not currently handled in `parseResponse`, the code should be updated to do so.", v);
specialinvoke v.<java.lang.AssertionError: void <init>(java.lang.Object)>(v);
throw v;
}
public boolean shouldClientThrottle(short)
{
short v;
org.apache.kafkaesque.common.requests.AbstractResponse v;
v := @this: org.apache.kafkaesque.common.requests.AbstractResponse;
v := @parameter: short;
return 0;
}
public int throttleTimeMs()
{
org.apache.kafkaesque.common.requests.AbstractResponse v;
v := @this: org.apache.kafkaesque.common.requests.AbstractResponse;
return 0;
}
public java.lang.String toString(short)
{
org.apache.kafkaesque.common.protocol.types.Struct v;
short v;
java.lang.String v;
org.apache.kafkaesque.common.requests.AbstractResponse v;
v := @this: org.apache.kafkaesque.common.requests.AbstractResponse;
v := @parameter: short;
v = virtualinvoke v.<org.apache.kafkaesque.common.requests.AbstractResponse: org.apache.kafkaesque.common.protocol.types.Struct toStruct(short)>(v);
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.String toString()>();
return v;
}
}