public interface KafkaMessage
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getKey()
Return the Kafka partition key.
|
java.lang.String |
getValue()
Return the value in the Kafka message.
|
void |
setKey(java.lang.String key)
Set the Kafka partition key.
|
void |
setValue(java.lang.String value)
Set the value in the Kafka message.
|
java.lang.String getKey()
void setKey(java.lang.String key)
key
- The new Kafka partition key.java.lang.String getValue()
void setValue(java.lang.String value)
value
- The new value in the Kafka message.