Package com.linkedin.venice.unit.kafka

Class InMemoryKafkaMessage

java.lang.Object

com.linkedin.venice.unit.kafka.InMemoryKafkaMessage

public class InMemoryKafkaMessage
extends Object

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

See Also:

• InMemoryKafkaTopic

Field Summary

Fields

Modifier and Type	Field	Description
final PubSubMessageHeaders	headers
final KafkaKey	key
final 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 Details

key

public final KafkaKey key

value

public final KafkaMessageEnvelope value

headers

public final PubSubMessageHeaders headers

Constructor Details

InMemoryKafkaMessage

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

Method Details

isPutValueChanged

public boolean isPutValueChanged()

putValueChanged

public void putValueChanged()