Package com.linkedin.venice.unit.kafka.producer
package com.linkedin.venice.unit.kafka.producer
-
ClassDescriptionA
PubSubProducerAdapter
implementation which interacts with theInMemoryKafkaBroker
in order to make unit tests more lightweight.ThisPubSubProducerAdapter
implementation allows tests to perform arbitrary transformations on the messages that are about to be written to Kafka.