public class KafkaMessage
extends java.lang.Object
kafka message
and its metadata
.Constructor and Description |
---|
KafkaMessage(kafka.message.Message message,
KafkaMessageMetadata metadata) |
Modifier and Type | Method and Description |
---|---|
kafka.message.Message |
getMessage() |
KafkaMessageMetadata |
getMetadata() |
java.lang.String |
toString() |
public KafkaMessage(kafka.message.Message message, KafkaMessageMetadata metadata)
public kafka.message.Message getMessage()
public KafkaMessageMetadata getMetadata()
public java.lang.String toString()
toString
in class java.lang.Object