io.confluent.kafka.multitenant

Class KafkaLogicalClusterMetadata

java.lang.Object

org.apache.kafka.server.multitenant.LogicalClusterMetadata

io.confluent.kafka.multitenant.KafkaLogicalClusterMetadata

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

Represents logical cluster metadata

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KafkaLogicalClusterMetadata.LifecycleMetadata

Field Summary

Fields

Modifier and Type	Field and Description
static Long	DEFAULT_HEALTHCHECK_MAX_CONSUMER_RATE
static Long	DEFAULT_HEALTHCHECK_MAX_PRODUCER_RATE
static Double	DEFAULT_LINK_REQUEST_PERCENTAGE_PER_BROKER
static Long	DEFAULT_MIN_NETWORK_BYTE_RATE
static Integer	DEFAULT_NETWORK_QUOTA_OVERHEAD_PERCENTAGE
static Double	DEFAULT_REQUEST_PERCENTAGE_PER_BROKER
static String	HEALTHCHECK_LOGICAL_CLUSTER_TYPE
static String	KAFKA_LOGICAL_CLUSTER_TYPE
static String	LINK_HEALTHCHECK_LOGICAL_CLUSTER_TYPE

Constructor Summary

Constructors

Constructor and Description

KafkaLogicalClusterMetadata(String logicalClusterId, String physicalClusterId, String logicalClusterName, String accountId, String k8sClusterId, String logicalClusterType, Long storageBytes, Long producerByteRate, Long consumerByteRate, Long maxProducerByteRate, Long maxConsumerByteRate, Long brokerRequestPercentage, Integer networkQuotaOverhead, KafkaLogicalClusterMetadata.LifecycleMetadata lifecycleMetadata, Integer maxPartitions, String organizationId, String environmentId, Long brokerLinkRequestPercentage, Map<org.apache.kafka.server.quota.ElasticCkuDefinitionKey,Integer> elasticCkuMetadata, Integer cku)

Method Summary

Modifier and Type	Method and Description
String	accountId()
Double	brokerLinkRequestPercentage()
Double	brokerRequestPercentage()
Integer	cku()
Long	consumerByteRate()
Date	creationDate()
Map<org.apache.kafka.server.quota.ElasticCkuDefinitionKey,Integer>	elasticCkuMetadata()
String	environmentId()
boolean	equals(Object o)
static KafkaLogicalClusterMetadata	fromProtobuf(io.confluent.protobuf.cloud.events.v1.LogicalCluster lc)
int	hashCode()
boolean	isActive()
boolean	isHealthcheckLogicalCluster() Returns true if this is a healthcheck logical cluster.
boolean	isValid() Returns true if metadata values are valid
String	k8sClusterId()
KafkaLogicalClusterMetadata.LifecycleMetadata	lifecycleMetadata()
String	logicalClusterId()
String	logicalClusterName()
String	logicalClusterType()
Integer	maxPartitions()
Integer	networkQuotaOverhead()
String	organizationId()
String	physicalClusterId()
Long	producerByteRate()
QuotaConfig	quotaConfig(double linkRequestPercentageMultipler)
Long	storageBytes()
String	toString()

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Field Detail

KAFKA_LOGICAL_CLUSTER_TYPE

public static final String KAFKA_LOGICAL_CLUSTER_TYPE

See Also:

Constant Field Values

HEALTHCHECK_LOGICAL_CLUSTER_TYPE

public static final String HEALTHCHECK_LOGICAL_CLUSTER_TYPE

See Also:

Constant Field Values

LINK_HEALTHCHECK_LOGICAL_CLUSTER_TYPE

public static final String LINK_HEALTHCHECK_LOGICAL_CLUSTER_TYPE

See Also:

Constant Field Values

DEFAULT_REQUEST_PERCENTAGE_PER_BROKER

public static final Double DEFAULT_REQUEST_PERCENTAGE_PER_BROKER

DEFAULT_LINK_REQUEST_PERCENTAGE_PER_BROKER

public static final Double DEFAULT_LINK_REQUEST_PERCENTAGE_PER_BROKER

DEFAULT_NETWORK_QUOTA_OVERHEAD_PERCENTAGE

public static final Integer DEFAULT_NETWORK_QUOTA_OVERHEAD_PERCENTAGE

DEFAULT_HEALTHCHECK_MAX_PRODUCER_RATE

public static final Long DEFAULT_HEALTHCHECK_MAX_PRODUCER_RATE

DEFAULT_HEALTHCHECK_MAX_CONSUMER_RATE

public static final Long DEFAULT_HEALTHCHECK_MAX_CONSUMER_RATE

DEFAULT_MIN_NETWORK_BYTE_RATE

public static final Long DEFAULT_MIN_NETWORK_BYTE_RATE

Constructor Detail

KafkaLogicalClusterMetadata

public KafkaLogicalClusterMetadata(String logicalClusterId,
                                   String physicalClusterId,
                                   String logicalClusterName,
                                   String accountId,
                                   String k8sClusterId,
                                   String logicalClusterType,
                                   Long storageBytes,
                                   Long producerByteRate,
                                   Long consumerByteRate,
                                   Long maxProducerByteRate,
                                   Long maxConsumerByteRate,
                                   Long brokerRequestPercentage,
                                   Integer networkQuotaOverhead,
                                   KafkaLogicalClusterMetadata.LifecycleMetadata lifecycleMetadata,
                                   Integer maxPartitions,
                                   String organizationId,
                                   String environmentId,
                                   Long brokerLinkRequestPercentage,
                                   Map<org.apache.kafka.server.quota.ElasticCkuDefinitionKey,Integer> elasticCkuMetadata,
                                   Integer cku)

Method Detail

fromProtobuf

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

creationDate

public Date creationDate()

Specified by:

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

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

cku

public Integer cku()

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

storageBytes

public Long storageBytes()

producerByteRate

public Long producerByteRate()

consumerByteRate

public Long consumerByteRate()

brokerRequestPercentage

public Double brokerRequestPercentage()

brokerLinkRequestPercentage

public Double brokerLinkRequestPercentage()

networkQuotaOverhead

public Integer networkQuotaOverhead()

lifecycleMetadata

public KafkaLogicalClusterMetadata.LifecycleMetadata lifecycleMetadata()

elasticCkuMetadata

public Map<org.apache.kafka.server.quota.ElasticCkuDefinitionKey,Integer> elasticCkuMetadata()

maxPartitions

public Integer maxPartitions()

isValid

public boolean isValid()

Returns true if metadata values are valid

Specified by:

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

isHealthcheckLogicalCluster

public final boolean isHealthcheckLogicalCluster()

Returns true if this is a healthcheck logical cluster.

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

quotaConfig

public QuotaConfig quotaConfig(double linkRequestPercentageMultipler)

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