Package com.linkedin.venice.unit.kafka
package com.linkedin.venice.unit.kafka
-
ClassesClassDescriptionUsed in unit tests in order to avoid spinning a full Kafka broker with network stack and disk IO.A single Kafka message, strongly typed for the types that Venice uses.This
VenicePartitionerimplementation 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.