Package com.linkedin.venice.pubsub

Class PubSubConstants

java.lang.Object
com.linkedin.venice.pubsub.PubSubConstants
public class PubSubConstants extends Object
Constants used by pub-sub components.

  • Field Details

    • PUBSUB_PRODUCER_USE_HIGH_THROUGHPUT_DEFAULTS

      public static final String PUBSUB_PRODUCER_USE_HIGH_THROUGHPUT_DEFAULTS
      See Also:

    • PUBSUB_CONSUMER_API_DEFAULT_TIMEOUT_MS

      public static final String PUBSUB_CONSUMER_API_DEFAULT_TIMEOUT_MS
      See Also:

    • PUBSUB_CONSUMER_API_DEFAULT_TIMEOUT_MS_DEFAULT_VALUE

      public static final int PUBSUB_CONSUMER_API_DEFAULT_TIMEOUT_MS_DEFAULT_VALUE
      See Also:

    • PUBSUB_CONSUMER_POLL_RETRY_TIMES

      public static final String PUBSUB_CONSUMER_POLL_RETRY_TIMES
      See Also:

    • PUBSUB_CONSUMER_POLL_RETRY_TIMES_DEFAULT_VALUE

      public static final int PUBSUB_CONSUMER_POLL_RETRY_TIMES_DEFAULT_VALUE
      See Also:

    • PUBSUB_CONSUMER_POLL_RETRY_BACKOFF_MS

      public static final String PUBSUB_CONSUMER_POLL_RETRY_BACKOFF_MS
      See Also:

    • PUBSUB_CONSUMER_POLL_RETRY_BACKOFF_MS_DEFAULT_VALUE

      public static final int PUBSUB_CONSUMER_POLL_RETRY_BACKOFF_MS_DEFAULT_VALUE
      See Also:

    • PUBSUB_CONSUMER_POSITION_RESET_STRATEGY

      public static final String PUBSUB_CONSUMER_POSITION_RESET_STRATEGY
      See Also:

    • PUBSUB_CONSUMER_POSITION_RESET_STRATEGY_DEFAULT_VALUE

      public static final String PUBSUB_CONSUMER_POSITION_RESET_STRATEGY_DEFAULT_VALUE
      See Also:

    • 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:

    • PUBSUB_TOPIC_UNKNOWN_RETENTION

      public static final long PUBSUB_TOPIC_UNKNOWN_RETENTION
      See Also:

    • PUBSUB_CONSUMER_TOPIC_QUERY_RETRY_TIMES

      public static final String PUBSUB_CONSUMER_TOPIC_QUERY_RETRY_TIMES
      See Also:

    • PUBSUB_CONSUMER_TOPIC_QUERY_RETRY_TIMES_DEFAULT_VALUE

      public static final int PUBSUB_CONSUMER_TOPIC_QUERY_RETRY_TIMES_DEFAULT_VALUE
      See Also:

    • PUBSUB_CONSUMER_TOPIC_QUERY_RETRY_INTERVAL_MS

      public static final String PUBSUB_CONSUMER_TOPIC_QUERY_RETRY_INTERVAL_MS
      See Also:

    • PUBSUB_CONSUMER_TOPIC_QUERY_RETRY_INTERVAL_MS_DEFAULT_VALUE

      public static final int PUBSUB_CONSUMER_TOPIC_QUERY_RETRY_INTERVAL_MS_DEFAULT_VALUE
      See Also:

    • PUBSUB_ADMIN_API_DEFAULT_TIMEOUT_MS

      public static final String PUBSUB_ADMIN_API_DEFAULT_TIMEOUT_MS
      See Also:

    • PUBSUB_ADMIN_API_DEFAULT_TIMEOUT_MS_DEFAULT_VALUE

      public static final int PUBSUB_ADMIN_API_DEFAULT_TIMEOUT_MS_DEFAULT_VALUE
      See Also:

    • PUBSUB_CONSUMER_CHECK_TOPIC_EXISTENCE

      public static final String PUBSUB_CONSUMER_CHECK_TOPIC_EXISTENCE
      See Also:

    • PUBSUB_CONSUMER_CHECK_TOPIC_EXISTENCE_DEFAULT_VALUE

      public static final boolean PUBSUB_CONSUMER_CHECK_TOPIC_EXISTENCE_DEFAULT_VALUE
      See Also:

    • 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:

    • CREATE_TOPIC_RETRIABLE_EXCEPTIONS

      public static final List<Class<? extends Throwable>> CREATE_TOPIC_RETRIABLE_EXCEPTIONS

    • TOPIC_METADATA_OP_RETRIABLE_EXCEPTIONS

      public static final List<Class<? extends Throwable>> TOPIC_METADATA_OP_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:

    • UNKNOWN_LATEST_OFFSET

      public static final long UNKNOWN_LATEST_OFFSET
      See Also:

    • PUBSUB_NO_PRODUCER_TIME_IN_EMPTY_TOPIC_PARTITION

      public static final long PUBSUB_NO_PRODUCER_TIME_IN_EMPTY_TOPIC_PARTITION
      See Also:

    • PUBSUB_CONSUMER_POLLING_FOR_METADATA_RETRY_MAX_ATTEMPT

      public static final int PUBSUB_CONSUMER_POLLING_FOR_METADATA_RETRY_MAX_ATTEMPT
      See Also:

    • 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:

    • PUBSUB_FAST_OPERATION_TIMEOUT_MS

      public static final int PUBSUB_FAST_OPERATION_TIMEOUT_MS
      See Also:

    • PUBSUB_OPERATION_TIMEOUT_MS_DEFAULT_VALUE

      public static final int PUBSUB_OPERATION_TIMEOUT_MS_DEFAULT_VALUE
      See Also:

    • PUBSUB_TOPIC_DELETE_RETRY_TIMES

      public static final int PUBSUB_TOPIC_DELETE_RETRY_TIMES
      See Also:

    • ETERNAL_TOPIC_RETENTION_POLICY_MS

      public static final long ETERNAL_TOPIC_RETENTION_POLICY_MS
      See Also:

    • DEFAULT_TOPIC_RETENTION_POLICY_MS

      public static final long DEFAULT_TOPIC_RETENTION_POLICY_MS
      See Also:

    • BUFFER_REPLAY_MINIMAL_SAFETY_MARGIN

      public static final long BUFFER_REPLAY_MINIMAL_SAFETY_MARGIN
      See Also:

    • DEFAULT_KAFKA_REPLICATION_FACTOR

      public static final int DEFAULT_KAFKA_REPLICATION_FACTOR
      See Also:

  • Constructor Details

    • PubSubConstants

      public PubSubConstants()

  • Method Details

    • getPubsubOffsetApiTimeoutDurationDefaultValue

      public static Duration getPubsubOffsetApiTimeoutDurationDefaultValue()