public class ProcessorRecordContext extends java.lang.Object implements RecordContext
Constructor and Description |
---|
ProcessorRecordContext(long timestamp,
long offset,
int partition,
java.lang.String topic) |
ProcessorRecordContext(long timestamp,
long offset,
int partition,
java.lang.String topic,
org.apache.kafka.common.header.Headers headers) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(java.lang.Object o) |
int |
hashCode() |
org.apache.kafka.common.header.Headers |
headers() |
long |
offset() |
int |
partition() |
void |
setTimestamp(long timestamp) |
long |
sizeBytes() |
long |
timestamp() |
java.lang.String |
topic() |
public ProcessorRecordContext(long timestamp, long offset, int partition, java.lang.String topic, org.apache.kafka.common.header.Headers headers)
public ProcessorRecordContext(long timestamp, long offset, int partition, java.lang.String topic)
public void setTimestamp(long timestamp)
public long offset()
offset
in interface RecordContext
public long timestamp()
timestamp
in interface RecordContext
public java.lang.String topic()
topic
in interface RecordContext
public int partition()
partition
in interface RecordContext
public org.apache.kafka.common.header.Headers headers()
headers
in interface RecordContext
public long sizeBytes()
public boolean equals(java.lang.Object o)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object