int partition
java.lang.String topic
int hash
org.apache.kafka.clients.consumer.OffsetAndMetadata offsetAndMetadata
OffsetAndMetadata
java.util.Map<K,V> headers
byte[] payload
java.lang.String causedByClass