public static class VerifiableConsumer.RecordData extends java.lang.Object
VerifiableConsumer.RecordData(org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.String,java.lang.String> record)
java.lang.String
key()
name()
long
offset()
int
partition()
topic()
value()
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public VerifiableConsumer.RecordData(org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.String,java.lang.String> record)
public java.lang.String name()
public java.lang.String topic()
public int partition()
public java.lang.String key()
public java.lang.String value()
public long offset()