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

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)