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.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.