Package com.linkedin.venice.unit.kafka
-
Class Summary Class Description InMemoryKafkaBroker Used in unit tests in order to avoid spinning a full Kafka broker with network stack and disk IO.InMemoryKafkaMessage A single Kafka message, strongly typed for the types that Venice uses.MockInMemoryAdminAdapter SimplePartitioner ThisVenicePartitioner
implementation takes the first byte of the key, and computes the partition as such: firstByte % numPartitions It is meant to be used in tests where we want to control the partition that a key belongs to, but without needing to work out a proper input that yields the desired partition when hashed by theDefaultVenicePartitioner
.