Package com.linkedin.venice.unit.kafka

Class InMemoryKafkaMessage

java.lang.Object

com.linkedin.venice.unit.kafka.InMemoryKafkaMessage

public class InMemoryKafkaMessage
extends java.lang.Object

A single Kafka message, strongly typed for the types that Venice uses.

See Also:

InMemoryKafkaTopic

Field Summary

Fields

Modifier and Type	Field	Description
PubSubMessageHeaders	headers
KafkaKey	key
KafkaMessageEnvelope	value

Constructor Summary

Constructors

Constructor	Description
InMemoryKafkaMessage(KafkaKey key, KafkaMessageEnvelope value, PubSubMessageHeaders headers)

Method Summary

Modifier and Type	Method	Description
boolean	isPutValueChanged()
void	putValueChanged()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

key

public final KafkaKey key

value

public final KafkaMessageEnvelope value

headers

public final PubSubMessageHeaders headers

Constructor Detail

InMemoryKafkaMessage

public InMemoryKafkaMessage(KafkaKey key,
                            KafkaMessageEnvelope value,
                            PubSubMessageHeaders headers)

Method Detail

isPutValueChanged

public boolean isPutValueChanged()

putValueChanged

public void putValueChanged()