public class org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord extends java.lang.Object
{
private final java.lang.String topic;
private final java.lang.Integer partition;
private final org.apache.kafkaesqueesqueesque.common.header.Headers headers;
private final java.lang.Object key;
private final java.lang.Object value;
private final java.lang.Long timestamp;
public void <init>(java.lang.String, java.lang.Integer, java.lang.Long, java.lang.Object, java.lang.Object, java.lang.Iterable)
{
java.lang.Object[] v, v;
long v;
java.lang.Integer v;
java.lang.Iterable v;
byte v;
java.lang.Long v;
org.apache.kafkaesqueesqueesque.common.header.internals.RecordHeaders v;
int v;
java.lang.String v, v, v;
org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord v;
java.lang.IllegalArgumentException v, v, v;
java.lang.Object v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Integer;
v := @parameter: java.lang.Long;
v := @parameter: java.lang.Object;
v := @parameter: java.lang.Object;
v := @parameter: java.lang.Iterable;
specialinvoke v.<java.lang.Object: void <init>()>();
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Topic cannot be null.");
throw v;
label:
if v == null goto label;
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v cmp 0L;
if v >= 0 goto label;
v = new java.lang.IllegalArgumentException;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Invalid timestamp: %d. Timestamp should always be non-negative or null.", v);
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
if v == null goto label;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v >= 0 goto label;
v = new java.lang.IllegalArgumentException;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Invalid partition: %d. Partition number should always be non-negative or null.", v);
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.String topic> = v;
v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Integer partition> = v;
v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Object key> = v;
v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Object value> = v;
v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Long timestamp> = v;
v = new org.apache.kafkaesqueesqueesque.common.header.internals.RecordHeaders;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.header.internals.RecordHeaders: void <init>(java.lang.Iterable)>(v);
v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: org.apache.kafkaesqueesqueesque.common.header.Headers headers> = v;
return;
}
public void <init>(java.lang.String, java.lang.Integer, java.lang.Long, java.lang.Object, java.lang.Object)
{
org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord v;
java.lang.Long v;
java.lang.Object v, v;
java.lang.String v;
java.lang.Integer v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Integer;
v := @parameter: java.lang.Long;
v := @parameter: java.lang.Object;
v := @parameter: java.lang.Object;
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: void <init>(java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Object,java.lang.Object,java.lang.Iterable)>(v, v, v, v, v, null);
return;
}
public void <init>(java.lang.String, java.lang.Integer, java.lang.Object, java.lang.Object, java.lang.Iterable)
{
org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord v;
java.lang.Object v, v;
java.lang.String v;
java.lang.Integer v;
java.lang.Iterable v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Integer;
v := @parameter: java.lang.Object;
v := @parameter: java.lang.Object;
v := @parameter: java.lang.Iterable;
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: void <init>(java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Object,java.lang.Object,java.lang.Iterable)>(v, v, null, v, v, v);
return;
}
public void <init>(java.lang.String, java.lang.Integer, java.lang.Object, java.lang.Object)
{
org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord v;
java.lang.Object v, v;
java.lang.String v;
java.lang.Integer v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Integer;
v := @parameter: java.lang.Object;
v := @parameter: java.lang.Object;
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: void <init>(java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Object,java.lang.Object,java.lang.Iterable)>(v, v, null, v, v, null);
return;
}
public void <init>(java.lang.String, java.lang.Object, java.lang.Object)
{
org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord v;
java.lang.Object v, v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Object;
v := @parameter: java.lang.Object;
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: void <init>(java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Object,java.lang.Object,java.lang.Iterable)>(v, null, null, v, v, null);
return;
}
public void <init>(java.lang.String, java.lang.Object)
{
java.lang.Object v;
org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Object;
specialinvoke v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: void <init>(java.lang.String,java.lang.Integer,java.lang.Long,java.lang.Object,java.lang.Object,java.lang.Iterable)>(v, null, null, null, v, null);
return;
}
public java.lang.String topic()
{
org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord v;
java.lang.String v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.String topic>;
return v;
}
public org.apache.kafkaesqueesqueesque.common.header.Headers headers()
{
org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord v;
org.apache.kafkaesqueesqueesque.common.header.Headers v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: org.apache.kafkaesqueesqueesque.common.header.Headers headers>;
return v;
}
public java.lang.Object key()
{
java.lang.Object v;
org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Object key>;
return v;
}
public java.lang.Object value()
{
java.lang.Object v;
org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Object value>;
return v;
}
public java.lang.Long timestamp()
{
org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord v;
java.lang.Long v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Long timestamp>;
return v;
}
public java.lang.Integer partition()
{
org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord v;
java.lang.Integer v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Integer partition>;
return v;
}
public java.lang.String toString()
{
java.lang.Integer v;
org.apache.kafkaesqueesqueesque.common.header.Headers v, v;
java.lang.Long v, v;
java.lang.String v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord v;
java.lang.Object v, v, v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: org.apache.kafkaesqueesqueesque.common.header.Headers headers>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: org.apache.kafkaesqueesqueesque.common.header.Headers headers>;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
label:
v = v;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Object key>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Object key>;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
label:
v = v;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Object value>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Object value>;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
label:
v = v;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Long timestamp>;
if v != null goto label;
v = "null";
goto label;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Long timestamp>;
v = virtualinvoke v.<java.lang.Long: java.lang.String toString()>();
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.String topic>;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Integer partition>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.Integer,java.lang.String,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, 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[])>("ProducerRecord(topic=\u, partition=\u, headers=\u, key=\u, value=\u, timestamp=\u)");
return v;
}
public boolean equals(java.lang.Object)
{
java.lang.Integer v, v;
org.apache.kafkaesqueesqueesque.common.header.Headers v, v;
java.lang.Long v, v;
java.lang.String v, v;
boolean v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord v;
java.lang.Object v, v, v, v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord;
v := @parameter: java.lang.Object;
if v != v goto label;
return 1;
label:
v = v instanceof org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord;
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Object key>;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Object key>;
v = staticinvoke <java.util.Objects: boolean equals(java.lang.Object,java.lang.Object)>(v, v);
if v == 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Integer partition>;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Integer partition>;
v = staticinvoke <java.util.Objects: boolean equals(java.lang.Object,java.lang.Object)>(v, v);
if v == 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.String topic>;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.String topic>;
v = staticinvoke <java.util.Objects: boolean equals(java.lang.Object,java.lang.Object)>(v, v);
if v == 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: org.apache.kafkaesqueesqueesque.common.header.Headers headers>;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: org.apache.kafkaesqueesqueesque.common.header.Headers headers>;
v = staticinvoke <java.util.Objects: boolean equals(java.lang.Object,java.lang.Object)>(v, v);
if v == 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Object value>;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Object value>;
v = staticinvoke <java.util.Objects: boolean equals(java.lang.Object,java.lang.Object)>(v, v);
if v == 0 goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Long timestamp>;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Long timestamp>;
v = staticinvoke <java.util.Objects: boolean equals(java.lang.Object,java.lang.Object)>(v, v);
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public int hashCode()
{
java.lang.Integer v, v;
org.apache.kafkaesqueesqueesque.common.header.Headers v, v;
java.lang.Long v, v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v;
org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord v;
java.lang.Object v, v, v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.String topic>;
if v == null goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.String topic>;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
goto label;
label:
v = 0;
label:
v = 31 * v;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Integer partition>;
if v == null goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Integer partition>;
v = virtualinvoke v.<java.lang.Integer: int hashCode()>();
goto label;
label:
v = 0;
label:
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: org.apache.kafkaesqueesqueesque.common.header.Headers headers>;
if v == null goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: org.apache.kafkaesqueesqueesque.common.header.Headers headers>;
v = virtualinvoke v.<java.lang.Object: int hashCode()>();
goto label;
label:
v = 0;
label:
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Object key>;
if v == null goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Object key>;
v = virtualinvoke v.<java.lang.Object: int hashCode()>();
goto label;
label:
v = 0;
label:
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Object value>;
if v == null goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Object value>;
v = virtualinvoke v.<java.lang.Object: int hashCode()>();
goto label;
label:
v = 0;
label:
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Long timestamp>;
if v == null goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.ProducerRecord: java.lang.Long timestamp>;
v = virtualinvoke v.<java.lang.Long: int hashCode()>();
goto label;
label:
v = 0;
label:
v = v + v;
return v;
}
}