Package com.linkedin.venice.controller.kafka

Class AdminTopicUtils

java.lang.Object

com.linkedin.venice.controller.kafka.AdminTopicUtils

public class AdminTopicUtils
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final int	ADMIN_TOPIC_PARTITION_ID
static final int	MAX_ADMIN_MESSAGE_PAYLOAD_SIZE_BYTES	Maximum serialized size of a single admin-topic record, enforced before allocating an execution id.
static final int	PARTITION_NUM_FOR_ADMIN_TOPIC

Constructor Summary

Constructors

Constructor	Description
AdminTopicUtils()

Method Summary

Modifier and Type	Method	Description
static String	getClusterNameFromTopicName(String topicName)
static String	getTopicNameFromClusterName(String clusterName)
static boolean	isAdminTopic(String topicName)
static boolean	isKafkaInternalTopic(String topicName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

PARTITION_NUM_FOR_ADMIN_TOPIC

public static final int PARTITION_NUM_FOR_ADMIN_TOPIC

See Also:

• Constant Field Values

ADMIN_TOPIC_PARTITION_ID

public static final int ADMIN_TOPIC_PARTITION_ID

See Also:

• Constant Field Values

MAX_ADMIN_MESSAGE_PAYLOAD_SIZE_BYTES

public static final int MAX_ADMIN_MESSAGE_PAYLOAD_SIZE_BYTES

Maximum serialized size of a single admin-topic record, enforced before allocating an execution id. Aliased to VeniceWriter.DEFAULT_MAX_SIZE_FOR_USER_PAYLOAD_PER_MESSAGE_IN_BYTES to track the producer's default rejection threshold, and is conservatively below ZK's jute.maxbuffer (~1 MB) so admin ops that pass this check will fit in the eventual znode.

Read as a compile-time constant rather than the writer's runtime getMaxSizeForUserPayloadPerMessageInBytes() so the pre-flight stays independent of whether Venice chunking or pubsub-large-message passthrough is enabled on the admin writer.

See Also:

• Constant Field Values

Constructor Details

AdminTopicUtils

public AdminTopicUtils()

Method Details

getTopicNameFromClusterName

public static String getTopicNameFromClusterName(String clusterName)

getClusterNameFromTopicName

public static String getClusterNameFromTopicName(String topicName)

isAdminTopic

public static boolean isAdminTopic(String topicName)

isKafkaInternalTopic

public static boolean isKafkaInternalTopic(String topicName)