Package com.linkedin.venice.pubsub.api
package com.linkedin.venice.pubsub.api
-
ClassDescriptionA default implementation of
PubSubMessagethat represents a message in a pub-sub system with aKafkaKeyas the key, aKafkaMessageEnvelopeas the value, and aPubSubPositionto track the message's offset within the topic-partition.An adapter for PubSubAdmin to create/delete/list/update topics.An adapter for consuming messages from a Pub-Sub topic.PubSubMessage<K,V, OFFSET> The class for deserializing messages from the pubsub specific message format toPubSubMessageA key-value pair that is associated with a messageSet of key-value pairs to tagged with messages produced to a topic.A serializer for PubSub messages that convertsKafkaKeyandKafkaMessageEnvelopeinto byte arrays for transmission over PubSub systems.Represents a position of a message in a partition of a topic.The pub-sub producer interface with which venice writer's interact to send messages to pub-sub topic.This class will spin up multiple producer instances to speed up the producing.Encapsulates all dependencies and configurations required to create a producer using a producer factory.A callback interface that users of PubSubProducerAdapter should implement if they want to execute some code once PubSubProducerAdapter#sendMessage request is completed.An interface implemented by specific PubSubProducerAdapters to return the result of a produce action.This enum is equivalent to Kafka's SecurityProtocol enum.