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