Class NonKafkaLogicalClusterMetadata

java.lang.Object

org.apache.kafka.server.multitenant.LogicalClusterMetadata

io.confluent.kafka.multitenant.NonKafkaLogicalClusterMetadata

public class NonKafkaLogicalClusterMetadata
extends org.apache.kafka.server.multitenant.LogicalClusterMetadata

Represents logical cluster metadata

Field Summary

Fields

Modifier and Type	Field	Description
static final String	KSQL_HEALTHCHECK_LOGICAL_CLUSTER_TYPE
static final String	KSQL_LOGICAL_CLUSTER_TYPE
static final String	SCHEMA_REGISTRY_HEALTHCHECK_LOGICAL_CLUSTER_TYPE
static final String	SCHEMA_REGISTRY_LOGICAL_CLUSTER_TYPE

Constructor Summary

Constructors

Constructor	Description
NonKafkaLogicalClusterMetadata(String logicalClusterId, String physicalClusterId, String logicalClusterName, String accountId, String k8sClusterId, String logicalClusterType, String organizationId, String environmentId, Date creationDate, Date deletionDate, String backingLogicalKafkaClusterId)

Method Summary

Modifier and Type	Method	Description
String	accountId()
String	backingLogicalKafkaClusterId()
Date	creationDate()
Date	deletionDate()
String	environmentId()
boolean	equals(Object o)
static NonKafkaLogicalClusterMetadata	fromProtobuf(io.confluent.protobuf.cloud.events.v1.LogicalCluster lc)
int	hashCode()
boolean	isActive()
boolean	isHealthcheckLogicalCluster()
boolean	isValid()	Returns true if metadata values are valid
String	k8sClusterId()
String	logicalClusterId()
String	logicalClusterName()
String	logicalClusterType()
String	organizationId()
String	physicalClusterId()
String	toString()

Methods inherited from class org.apache.kafka.server.multitenant.LogicalClusterMetadata

defaultK2TopicType

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Field Details

SCHEMA_REGISTRY_LOGICAL_CLUSTER_TYPE

public static final String SCHEMA_REGISTRY_LOGICAL_CLUSTER_TYPE

See Also:

• Constant Field Values

SCHEMA_REGISTRY_HEALTHCHECK_LOGICAL_CLUSTER_TYPE

public static final String SCHEMA_REGISTRY_HEALTHCHECK_LOGICAL_CLUSTER_TYPE

See Also:

• Constant Field Values

KSQL_LOGICAL_CLUSTER_TYPE

public static final String KSQL_LOGICAL_CLUSTER_TYPE

See Also:

• Constant Field Values

KSQL_HEALTHCHECK_LOGICAL_CLUSTER_TYPE

public static final String KSQL_HEALTHCHECK_LOGICAL_CLUSTER_TYPE

See Also:

• Constant Field Values

Constructor Details

NonKafkaLogicalClusterMetadata

public NonKafkaLogicalClusterMetadata(String logicalClusterId,
 String physicalClusterId,
 String logicalClusterName,
 String accountId,
 String k8sClusterId,
 String logicalClusterType,
 String organizationId,
 String environmentId,
 Date creationDate,
 Date deletionDate,
 String backingLogicalKafkaClusterId)

Method Details

fromProtobuf

public static NonKafkaLogicalClusterMetadata fromProtobuf(io.confluent.protobuf.cloud.events.v1.LogicalCluster lc)

logicalClusterId

public String logicalClusterId()

Specified by:

logicalClusterId in class org.apache.kafka.server.multitenant.LogicalClusterMetadata

physicalClusterId

public String physicalClusterId()

logicalClusterName

public String logicalClusterName()

accountId

public String accountId()

organizationId

public String organizationId()

Specified by:

organizationId in class org.apache.kafka.server.multitenant.LogicalClusterMetadata

environmentId

public String environmentId()

Specified by:

environmentId in class org.apache.kafka.server.multitenant.LogicalClusterMetadata

k8sClusterId

public String k8sClusterId()

logicalClusterType

public String logicalClusterType()

creationDate

public Date creationDate()

Specified by:

creationDate in class org.apache.kafka.server.multitenant.LogicalClusterMetadata

deletionDate

public Date deletionDate()

backingLogicalKafkaClusterId

public String backingLogicalKafkaClusterId()

isValid

public boolean isValid()

Returns true if metadata values are valid

Specified by:

isValid in class org.apache.kafka.server.multitenant.LogicalClusterMetadata

isHealthcheckLogicalCluster

public boolean isHealthcheckLogicalCluster()

Specified by:

isHealthcheckLogicalCluster in class org.apache.kafka.server.multitenant.LogicalClusterMetadata

isActive

public boolean isActive()

Specified by:

isActive in class org.apache.kafka.server.multitenant.LogicalClusterMetadata

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object