Package com.linkedin.venice.pubsub

Class PubSubConstants

  • public class PubSubConstants
extends java.lang.Object
    Constants used by pub-sub components.

    • Field Detail

      • PUBSUB_PRODUCER_USE_HIGH_THROUGHPUT_DEFAULTS

        public static final java.lang.String PUBSUB_PRODUCER_USE_HIGH_THROUGHPUT_DEFAULTS
        See Also:
        Constant Field Values

      • PUBSUB_CONSUMER_API_DEFAULT_TIMEOUT_MS

        public static final java.lang.String PUBSUB_CONSUMER_API_DEFAULT_TIMEOUT_MS
        See Also:
        Constant Field Values

      • PUBSUB_CONSUMER_API_DEFAULT_TIMEOUT_MS_DEFAULT_VALUE

        public static final int PUBSUB_CONSUMER_API_DEFAULT_TIMEOUT_MS_DEFAULT_VALUE
        See Also:
        Constant Field Values

      • PUBSUB_CONSUMER_POLL_RETRY_TIMES

        public static final java.lang.String PUBSUB_CONSUMER_POLL_RETRY_TIMES
        See Also:
        Constant Field Values

      • PUBSUB_CONSUMER_POLL_RETRY_TIMES_DEFAULT_VALUE

        public static final int PUBSUB_CONSUMER_POLL_RETRY_TIMES_DEFAULT_VALUE
        See Also:
        Constant Field Values

      • PUBSUB_CONSUMER_POLL_RETRY_BACKOFF_MS

        public static final java.lang.String PUBSUB_CONSUMER_POLL_RETRY_BACKOFF_MS
        See Also:
        Constant Field Values

      • PUBSUB_CONSUMER_POLL_RETRY_BACKOFF_MS_DEFAULT_VALUE

        public static final int PUBSUB_CONSUMER_POLL_RETRY_BACKOFF_MS_DEFAULT_VALUE
        See Also:
        Constant Field Values

      • PUBSUB_CONSUMER_POSITION_RESET_STRATEGY

        public static final java.lang.String PUBSUB_CONSUMER_POSITION_RESET_STRATEGY
        See Also:
        Constant Field Values

      • PUBSUB_CONSUMER_POSITION_RESET_STRATEGY_DEFAULT_VALUE

        public static final java.lang.String PUBSUB_CONSUMER_POSITION_RESET_STRATEGY_DEFAULT_VALUE
        See Also:
        Constant Field Values

      • PUBSUB_ADMIN_GET_TOPIC_CONFIG_RETRY_IN_SECONDS_DEFAULT_VALUE

        public static final long PUBSUB_ADMIN_GET_TOPIC_CONFIG_RETRY_IN_SECONDS_DEFAULT_VALUE
        See Also:
        Constant Field Values

      • PUBSUB_TOPIC_UNKNOWN_RETENTION

        public static final long PUBSUB_TOPIC_UNKNOWN_RETENTION
        See Also:
        Constant Field Values

      • PUBSUB_CONSUMER_TOPIC_QUERY_RETRY_TIMES

        public static final java.lang.String PUBSUB_CONSUMER_TOPIC_QUERY_RETRY_TIMES
        See Also:
        Constant Field Values

      • PUBSUB_CONSUMER_TOPIC_QUERY_RETRY_TIMES_DEFAULT_VALUE

        public static final int PUBSUB_CONSUMER_TOPIC_QUERY_RETRY_TIMES_DEFAULT_VALUE
        See Also:
        Constant Field Values

      • PUBSUB_CONSUMER_TOPIC_QUERY_RETRY_INTERVAL_MS

        public static final java.lang.String PUBSUB_CONSUMER_TOPIC_QUERY_RETRY_INTERVAL_MS
        See Also:
        Constant Field Values

      • PUBSUB_CONSUMER_TOPIC_QUERY_RETRY_INTERVAL_MS_DEFAULT_VALUE

        public static final int PUBSUB_CONSUMER_TOPIC_QUERY_RETRY_INTERVAL_MS_DEFAULT_VALUE
        See Also:
        Constant Field Values

      • PUBSUB_ADMIN_API_DEFAULT_TIMEOUT_MS

        public static final java.lang.String PUBSUB_ADMIN_API_DEFAULT_TIMEOUT_MS
        See Also:
        Constant Field Values

      • PUBSUB_ADMIN_API_DEFAULT_TIMEOUT_MS_DEFAULT_VALUE

        public static final int PUBSUB_ADMIN_API_DEFAULT_TIMEOUT_MS_DEFAULT_VALUE
        See Also:
        Constant Field Values

      • PUBSUB_CONSUMER_CHECK_TOPIC_EXISTENCE

        public static final java.lang.String PUBSUB_CONSUMER_CHECK_TOPIC_EXISTENCE
        See Also:
        Constant Field Values

      • PUBSUB_CONSUMER_CHECK_TOPIC_EXISTENCE_DEFAULT_VALUE

        public static final boolean PUBSUB_CONSUMER_CHECK_TOPIC_EXISTENCE_DEFAULT_VALUE
        See Also:
        Constant Field Values

      • DEFAULT_KAFKA_MIN_LOG_COMPACTION_LAG_MS

        public static final long DEFAULT_KAFKA_MIN_LOG_COMPACTION_LAG_MS
        Default setting is that no log compaction should happen for hybrid store version topics if the messages are produced within 24 hours; otherwise servers could encounter MISSING data DIV errors for reprocessing jobs which could potentially generate lots of duplicate keys.
        See Also:
        Constant Field Values

      • CREATE_TOPIC_RETRIABLE_EXCEPTIONS

        public static final java.util.List<java.lang.Class<? extends java.lang.Throwable>> CREATE_TOPIC_RETRIABLE_EXCEPTIONS

      • PUBSUB_TOPIC_DELETION_STATUS_POLL_INTERVAL_MS_DEFAULT_VALUE

        public static final int PUBSUB_TOPIC_DELETION_STATUS_POLL_INTERVAL_MS_DEFAULT_VALUE
        Default value of sleep interval for polling topic deletion status from ZK.
        See Also:
        Constant Field Values

      • PUBSUB_NO_PRODUCER_TIME_IN_EMPTY_TOPIC_PARTITION

        public static final long PUBSUB_NO_PRODUCER_TIME_IN_EMPTY_TOPIC_PARTITION
        See Also:
        Constant Field Values

      • PUBSUB_CONSUMER_POLLING_FOR_METADATA_RETRY_MAX_ATTEMPT

        public static final int PUBSUB_CONSUMER_POLLING_FOR_METADATA_RETRY_MAX_ATTEMPT
        See Also:
        Constant Field Values

      • PUBSUB_TOPIC_MANAGER_METADATA_FETCHER_CONSUMER_POOL_SIZE_DEFAULT_VALUE

        public static final int PUBSUB_TOPIC_MANAGER_METADATA_FETCHER_CONSUMER_POOL_SIZE_DEFAULT_VALUE
        See Also:
        Constant Field Values

      • PUBSUB_FAST_OPERATION_TIMEOUT_MS

        public static final int PUBSUB_FAST_OPERATION_TIMEOUT_MS
        See Also:
        Constant Field Values

      • PUBSUB_OPERATION_TIMEOUT_MS_DEFAULT_VALUE

        public static final int PUBSUB_OPERATION_TIMEOUT_MS_DEFAULT_VALUE
        See Also:
        Constant Field Values

      • PUBSUB_TOPIC_DELETE_RETRY_TIMES

        public static final int PUBSUB_TOPIC_DELETE_RETRY_TIMES
        See Also:
        Constant Field Values

      • ETERNAL_TOPIC_RETENTION_POLICY_MS

        public static final long ETERNAL_TOPIC_RETENTION_POLICY_MS
        See Also:
        Constant Field Values

      • DEFAULT_TOPIC_RETENTION_POLICY_MS

        public static final long DEFAULT_TOPIC_RETENTION_POLICY_MS
        See Also:
        Constant Field Values

      • BUFFER_REPLAY_MINIMAL_SAFETY_MARGIN

        public static final long BUFFER_REPLAY_MINIMAL_SAFETY_MARGIN
        See Also:
        Constant Field Values

      • DEFAULT_KAFKA_REPLICATION_FACTOR

        public static final int DEFAULT_KAFKA_REPLICATION_FACTOR
        See Also:
        Constant Field Values

    • Constructor Detail

      • PubSubConstants

        public PubSubConstants()

    • Method Detail

      • getPubsubOffsetApiTimeoutDurationDefaultValue

        public static java.time.Duration getPubsubOffsetApiTimeoutDurationDefaultValue()