Package com.linkedin.venice.pubsub
package com.linkedin.venice.pubsub
-
ClassDescriptionA
PubSubPositionFactoryfor the symbolicPubSubSymbolicPosition.EARLIESTmarker.APubSubPositionFactoryfor the symbolicPubSubSymbolicPosition.LATESTmarker.PubSubAdminAdapterFactory<ADAPTER extends PubSubAdminAdapter>Generic factory interface for creating PubSub system-specific admin instances.A wrapper around pub-sub producer, consumer, and admin adapter factories This will be passed as one of the arguments to the component which depends on the pub-sub APIs.Constants used by pub-sub components.The purpose of this class is only to make the package private test-only functions ofPubSubConstantsavailable to all packages within tests.Encapsulates all dependencies and configurations required to create a consumer using a consumer factory.PubSubConsumerAdapterFactory<ADAPTER extends PubSubConsumerAdapter>Generic factory interface for creating PubSub consumers.PubSubContextis a container class that holds all the core components required for managing PubSub infrastructure, including topic managers, position registry, position deserializer, and topic repository.Utility for converting serializedPubSubPositionWireFormatdata into concretePubSubPositioninstances using a configuredPubSubPositionTypeRegistry.A factory interface for creatingPubSubPositioninstances and resolving their associated class names.A configurable registry that maintains a bidirectional mapping betweenPubSubPositionFactoryimplementation class names (fully qualified) and their corresponding integer type IDs.Encapsulates all dependencies and configurations required to create a producer using a producer factory.PubSubProducerAdapterFactory<ADAPTER extends PubSubProducerAdapter>Generic factory interface for creating PubSub producers.Represents aPubSubTopicconfiguration.PubSubUtil.OffsetExtractor<T extends PubSubPosition>