Package com.linkedin.venice.controller.kafka

Class AdminTopicUtils

java.lang.Object

com.linkedin.venice.controller.kafka.AdminTopicUtils

public class AdminTopicUtils
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
static int	ADMIN_TOPIC_PARTITION_ID
static int	PARTITION_NUM_FOR_ADMIN_TOPIC

Constructor Summary

Constructors

Constructor	Description
AdminTopicUtils()

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

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 Detail

AdminTopicUtils

public AdminTopicUtils()

Method Detail

getTopicNameFromClusterName

public static java.lang.String getTopicNameFromClusterName(java.lang.String clusterName)

getClusterNameFromTopicName

public static java.lang.String getClusterNameFromTopicName(java.lang.String topicName)

isAdminTopic

public static boolean isAdminTopic(java.lang.String topicName)

isKafkaInternalTopic

public static boolean isKafkaInternalTopic(java.lang.String topicName)