Skip navigation links
A B C D E F G H I K L M N O P Q R S T U V W Z 

A

abort() - Method in class io.confluent.kafka.server.plugins.auth.FileBasedLoginModule
 
abort() - Method in class io.confluent.kafka.server.plugins.auth.TopicBasedLoginModule
 
AbstractConnectionSensorBuilder - Class in io.confluent.kafka.multitenant.metrics
 
AbstractConnectionSensorBuilder(Metrics, TenantMetrics.TenantMetricsContext) - Constructor for class io.confluent.kafka.multitenant.metrics.AbstractConnectionSensorBuilder
 
AbstractConnectionSensorBuilder.ConnectionCountSensorCreator - Class in io.confluent.kafka.multitenant.metrics
 
AbstractConnectionSensorBuilder.ConnectionMeterSensorCreator - Class in io.confluent.kafka.multitenant.metrics
 
AbstractPolicyConfig - Class in io.confluent.kafka.server.plugins.policy
 
AbstractPolicyConfig(ConfigDef, Map<String, ?>) - Constructor for class io.confluent.kafka.server.plugins.policy.AbstractPolicyConfig
 
accessRule(AclEntry) - Static method in class io.confluent.kafka.security.authorizer.acl.AclMapper
 
ACCOUNT_ID_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
accountId() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
ACL_SYNC_MS_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
ACL_SYNC_MS_MAX_CONFIG_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
ACL_SYNC_MS_MIN_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
ACL_SYNC_MS_MIN_CONFIG_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
AclMapper - Class in io.confluent.kafka.security.authorizer.acl
Maps Kafka ACL and related classes to Confluent cross-component authorization classes.
AclMapper() - Constructor for class io.confluent.kafka.security.authorizer.acl.AclMapper
 
aclOperation(Operation) - Static method in class io.confluent.kafka.security.authorizer.acl.AclMapper
 
AclProvider - Class in io.confluent.kafka.security.authorizer.acl
 
AclProvider() - Constructor for class io.confluent.kafka.security.authorizer.acl.AclProvider
 
acls(AclBindingFilter) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
acls(AclBindingFilter) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
actionForAuthorizeByResourceType(RequestContext, Operation, ResourceType) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
activeAuthenticatedConnectionsCount - Variable in class io.confluent.kafka.multitenant.metrics.ConnectionSensors
 
addMatchingRules(ResourceAuthorizeRules, KafkaPrincipal, Set<KafkaPrincipal>, String, Operation, Scope, ResourceType) - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
 
addRepeatedField(Descriptors.FieldDescriptor, Object) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
 
address() - Method in class io.confluent.common.EndPoint
 
addTenantPrefix(String) - Method in class io.confluent.kafka.multitenant.schema.TenantContext
 
AggregateTenantMetricsContext(ApiKeys) - Constructor for class io.confluent.kafka.multitenant.metrics.TenantMetrics.AggregateTenantMetricsContext
 
ALTER_ENABLE_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig
 
AlterConfigPolicy - Class in io.confluent.kafka.server.plugins.policy
 
AlterConfigPolicy() - Constructor for class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy
 
AlterConfigPolicy.ClusterPolicyConfig - Class in io.confluent.kafka.server.plugins.policy
 
apiKey() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.AggregateTenantMetricsContext
 
apiKey() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.MetricsRequestContext
 
APP_NAME_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
AuthAttemptCache - Class in io.confluent.kafka.server.plugins.auth
Caches authentication attempts, whether successful or unsuccessful.
AuthAttemptCache(long, int, Time, int) - Constructor for class io.confluent.kafka.server.plugins.auth.AuthAttemptCache
Create an AuthAttemptCache.
AuthAttemptCache() - Constructor for class io.confluent.kafka.server.plugins.auth.AuthAttemptCache
Create an AuthAttemptCache using default values of ttl and maxSize
authenticate(String, String, Optional<PathAwareSniHostName>) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslAuthenticator
Authenticate user by checking username, password and cluster id.
AUTHENTICATION_FAILED_MSG - Static variable in class io.confluent.kafka.server.plugins.auth.PlainSaslAuthenticator
Visible for testing
authenticationContext() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent
 
authenticationException() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent
 
authenticationId() - Method in interface io.confluent.kafka.multitenant.MultiTenantSaslServer
 
authenticationId() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer
 
AuthenticationStats - Class in io.confluent.kafka.server.plugins.auth.stats
 
AuthenticationStatsMBean - Interface in io.confluent.kafka.server.plugins.auth.stats
 
authorize(AuthorizableRequestContext, List<Action>) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
authorize(AuthorizableRequestContext, List<Action>) - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
authorize(AuthorizableRequestContext, List<Action>) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
authorizeByResourceType(AuthorizableRequestContext, AclOperation, ResourceType) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
authRate - Variable in class io.confluent.kafka.multitenant.metrics.ConnectionSensors
 
AVAILABILITY_CHECK_MS_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
AVAILABILITY_CHECK_MS_MAX_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
AVAILABILITY_CHECK_MS_MIN_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
AVAILABILITY_CHECK_MS_MIN_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 

B

BACKING_LOGICAL_KAFKA_CLUSTER_ID_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
BASE_PREFIX - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
BASE_PREFIX - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
BasePhysicalClusterMetadata - Class in io.confluent.kafka.multitenant
Base class for the PhysicalClusterMetadata plugins, interfacing with other confluent plugins
BasePhysicalClusterMetadata() - Constructor for class io.confluent.kafka.multitenant.BasePhysicalClusterMetadata
 
BROKER_REQUEST_PERCENTAGE_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
brokerRequestPercentage() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
build() - Method in class io.confluent.kafka.multitenant.metrics.ConnectionSensorBuilder
 
build() - Method in class io.confluent.kafka.multitenant.metrics.IpConnectionSensorBuilder
 
build() - Method in class io.confluent.kafka.multitenant.metrics.PartitionSensorBuilder
 
build(AuthenticationContext) - Method in class io.confluent.kafka.multitenant.MultiTenantPrincipalBuilder
 
build(AuthenticationContext) - Method in class io.confluent.kafka.multitenant.UserTenantPrincipalBuilder
 
build() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
 
build() - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
 
build() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
 
buildPartial() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
 
buildPartial() - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
 
buildPartial() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
 
buildResponseSend(AbstractResponse) - Method in class io.confluent.kafka.multitenant.MultiTenantRequestContext
 

C

CCLOUD_INTERNAL_USER - Static variable in class io.confluent.kafka.multitenant.MultiTenantPrincipalBuilder
 
centralizedAclProvider() - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
ChangeEventMetadata - Class in io.confluent.protobuf.cloud.events.v1
Metadata for the DB change event, which are useful for troubleshooting and audit.
ChangeEventMetadata.Builder - Class in io.confluent.protobuf.cloud.events.v1
Metadata for the DB change event, which are useful for troubleshooting and audit.
ChangeEventMetadataOrBuilder - Interface in io.confluent.protobuf.cloud.events.v1
 
checkPolicyMax(Map<String, String>, String, String) - Method in class io.confluent.kafka.server.plugins.policy.AbstractPolicyConfig
 
checkPolicyMin(Map<String, String>, String, String) - Method in class io.confluent.kafka.server.plugins.policy.AbstractPolicyConfig
 
clear() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
 
clear() - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
 
clear() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
 
clearAccountId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string account_id = 5;
clearAppName() - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
The app name is a global unique name for each pipeline.
clearBackingLogicalKafkaClusterId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
backing kafka cluster for ksql/schema-registry
clearBrokerRequestPercentage() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
uint64 broker_request_percentage = 25;
clearConfig() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string config = 6;
clearCreated() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp created = 7;
clearDeactivated() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp deactivated = 9;
clearDeploymentId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string deployment_id = 12;
clearEnvironmentId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string environment_id = 17;
clearField(Descriptors.FieldDescriptor) - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
 
clearField(Descriptors.FieldDescriptor) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
 
clearId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
Actual data for the change event.
clearK8SClusterId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string k8s_cluster_id = 20;
clearLastChangeId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
int64 last_change_id = 13;
clearLogicalClusterId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
Legacy fields from cc-structs/operator/v1/logicalkafkacluster.proto
clearLogicalClusterName() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string logical_cluster_name = 19;
clearLogicalClusterType() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string logical_cluster_type = 21;
clearLsn() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
DB log sequence number for the change event
clearMaxNetworkEgressByteRate() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
uint64 max_network_egress_byte_rate = 27;
clearMaxNetworkIngressByteRate() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
uint64 max_network_ingress_byte_rate = 26;
clearMaxPartitions() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
int32 max_partitions = 28;
clearMetadata() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
Metadata for the change event.
clearModified() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp modified = 8;
clearName() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string name = 2;
clearNetworkEgressByteRate() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
uint64 network_egress_byte_rate = 24;
clearNetworkIngressByteRate() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
uint64 network_ingress_byte_rate = 23;
clearOneof(Descriptors.OneofDescriptor) - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
 
clearOneof(Descriptors.OneofDescriptor) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
 
clearOp() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
DB operation for the change event: "c" => insert, "u"->update; "d"->delete
clearOrganizationId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
int32 organization_id = 14;
clearOrgResourceId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string org_resource_id = 16;
clearPhysicalClusterId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string physical_cluster_id = 3;
clearSequenceId() - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
We can't use an exactly once ordering here (yet), and thus consumers need a way to distinguish replayed messages from the most updated one.
clearStatusDetail() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string status_detail = 10;
clearStatusModified() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp status_modified = 11;
clearStorageBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
uint64 storage_bytes = 22;
clearTransactionId() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
DB transaction id for the change event
clearType() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string type = 4;
clientId() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.MetricsRequestContext
 
clone() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
 
clone() - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
 
clone() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
 
close(String) - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
 
close() - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
 
close() - Method in class io.confluent.kafka.multitenant.SslCertificateManager
 
close() - Method in class io.confluent.kafka.multitenant.TenantLifecycleManager
 
close(String) - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
close() - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsStore
 
close() - Method in class io.confluent.kafka.server.plugins.auth.oauth.OAuthBearerServerLoginCallbackHandler
 
close() - Method in class io.confluent.kafka.server.plugins.auth.oauth.OAuthBearerValidatorCallbackHandler
 
close() - Method in class io.confluent.kafka.server.plugins.auth.token.TokenBearerServerLoginCallbackHandler
 
close() - Method in class io.confluent.kafka.server.plugins.auth.token.TokenBearerValidatorCallbackHandler
 
close() - Method in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy
 
close() - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy
 
cluster - Variable in class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignorBuilder
 
cluster() - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
 
CLUSTER_LINK_PREFIX - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
clusterId(String) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslAuthenticator
 
ClusterLinkApis - Class in io.confluent.kafka.link
 
ClusterLinkApis() - Constructor for class io.confluent.kafka.link.ClusterLinkApis
 
ClusterLinkInterceptor - Class in io.confluent.kafka.link
 
ClusterLinkInterceptor() - Constructor for class io.confluent.kafka.link.ClusterLinkInterceptor
 
ClusterLinkPolicyConfig - Class in io.confluent.kafka.server.plugins.policy
 
ClusterLinkPolicyConfig(Map<String, ?>) - Constructor for class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
clusterLinkRestrictTopicConfigs(Map<String, String>) - Method in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy
 
clusterLinkValidateTopicConfigs(Map<String, String>) - Method in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy
 
commit() - Method in class io.confluent.kafka.server.plugins.auth.FileBasedLoginModule
 
commit() - Method in class io.confluent.kafka.server.plugins.auth.TopicBasedLoginModule
 
Common - Class in io.confluent.protobuf.cloud.events.v1
 
computeAssignmentForExistingTopic(TopicReplicaAssignor.NewPartitions, Optional<TopicPlacement>, Set<Integer>) - Method in class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignor
Computes the replica assignment for an existing topic that is about to have new partitions created on it (CreatePartitions request).
computeAssignmentForNewTopic(TopicReplicaAssignor.NewPartitions, Optional<TopicPlacement>, Set<Integer>) - Method in class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignor
Computes the replica assignment for a topic that's about to be created (CreateTopics request).
CONFIG_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
CONFIG_PREFIX - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig
 
configure(Map<String, ?>) - Method in class io.confluent.kafka.link.ClusterLinkInterceptor
 
configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignorBuilder
 
configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptor
 
configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.MultiTenantPrincipalBuilder
 
configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
Loads the cache and starts listening for directory events in directory specified in ConfluentConfigs.MULTITENANT_METADATA_DIR_CONFIG config.
configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
 
configure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
Creates a consumer for the LKC metadata topic (named in the ConfluentConfigs.CDC_LKC_METADATA_TOPIC_CONFIG config.) Adds the instance for the given broker session UUID, specified in KafkaConfig.BrokerSessionUuidProp to the static instance map.
configure(Map<String, ?>) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
configure(Map<String, ?>) - Method in class io.confluent.kafka.security.ldap.authorizer.LdapAuthorizer
 
configure(Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsStore
 
configure(Map<String, ?>, String, List<AppConfigurationEntry>) - Method in class io.confluent.kafka.server.plugins.auth.oauth.OAuthBearerServerLoginCallbackHandler
 
configure(Map<String, ?>, String, List<AppConfigurationEntry>) - Method in class io.confluent.kafka.server.plugins.auth.oauth.OAuthBearerValidatorCallbackHandler
 
configure(Map<String, ?>, String, List<AppConfigurationEntry>) - Method in class io.confluent.kafka.server.plugins.auth.token.TokenBearerServerLoginCallbackHandler
 
configure(Map<String, ?>, String, List<AppConfigurationEntry>) - Method in class io.confluent.kafka.server.plugins.auth.token.TokenBearerValidatorCallbackHandler
 
configure(Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy
 
configure(Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.policy.CreateClusterLinkPolicy
 
configure(Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy
 
configureAccessRuleProviders(Map<String, Object>) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
configureMetrics(Metrics) - Method in class io.confluent.kafka.link.ClusterLinkInterceptor
 
configureProviders(List<AccessRuleProvider>, GroupProvider, MetadataProvider, AuditLogProvider) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
configureServerInfo(ConfluentAuthorizerServerInfo) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
ConfluentAuthenticationEvent - Class in io.confluent.kafka.security.audit.event
 
ConfluentAuthenticationEvent(AuthenticationEvent, Scope) - Constructor for class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent
 
ConfluentServerAuthorizer - Class in io.confluent.kafka.security.authorizer
 
ConfluentServerAuthorizer() - Constructor for class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
ConnectionSensorBuilder - Class in io.confluent.kafka.multitenant.metrics
 
ConnectionSensorBuilder(Metrics, MultiTenantPrincipal) - Constructor for class io.confluent.kafka.multitenant.metrics.ConnectionSensorBuilder
 
ConnectionSensors - Class in io.confluent.kafka.multitenant.metrics
 
ConnectionSensors(Sensor, Sensor) - Constructor for class io.confluent.kafka.multitenant.metrics.ConnectionSensors
 
connectionString() - Method in class io.confluent.common.EndPoint
 
CONSUMER_OFFSET_SYNC_MS_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
CONSUMER_OFFSET_SYNC_MS_MAX_CONFIG_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
CONSUMER_OFFSET_SYNC_MS_MIN_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
CONSUMER_OFFSET_SYNC_MS_MIN_CONFIG_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
consumerByteRate() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
createAcls(AuthorizableRequestContext, List<AclBinding>) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
createAcls(AuthorizableRequestContext, List<AclBinding>, Optional<String>) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
createAcls(AuthorizableRequestContext, List<AclBinding>) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
createAcls(AuthorizableRequestContext, List<AclBinding>, Optional<String>) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
createAdminClient(String) - Method in class io.confluent.kafka.multitenant.SslCertificateManager
 
createAdminClient(String) - Method in class io.confluent.kafka.multitenant.TenantLifecycleManager
 
createAdminClient(String) - Static method in class io.confluent.kafka.multitenant.utils.Utils
 
CreateClusterLinkPolicy - Class in io.confluent.kafka.server.plugins.policy
Enforce the policy when creating the cluster links, for example enforcing maximum number of cluster links per tenant.
CreateClusterLinkPolicy() - Constructor for class io.confluent.kafka.server.plugins.policy.CreateClusterLinkPolicy
 
CREATED_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
createSaslServer(String, String, String, Map<String, ?>, CallbackHandler) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer.PlainSaslServerFactory
 
createSensor(Map<T, ? extends AbstractSensorCreator>, T, String) - Method in class io.confluent.kafka.multitenant.metrics.AbstractConnectionSensorBuilder
 
createSensor(Map<T, ? extends AbstractSensorCreator>, T, String) - Method in class io.confluent.kafka.multitenant.metrics.PartitionSensorBuilder
 
CreateTopicPolicy - Class in io.confluent.kafka.server.plugins.policy
 
CreateTopicPolicy() - Constructor for class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy
 
creationDate() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata.LifecycleMetadata
 

D

data() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent
 
DEACTIVATED_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
dedicatedLogicalClusterId() - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
 
dedicatedLogicalClusterId() - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
DEFAULT_ACL_SYNC_MS_MAX - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
DEFAULT_ACL_SYNC_MS_MIN - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
DEFAULT_AVAILABILITY_CHECK_MS_MAX - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
DEFAULT_AVAILABILITY_CHECK_MS_MIN - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
DEFAULT_CONSUMER_OFFSET_SYNC_MS_MAX - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
DEFAULT_CONSUMER_OFFSET_SYNC_MS_MIN - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
DEFAULT_DELETE_RETENTION_MS_MAX - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
DEFAULT_HEALTHCHECK_MAX_CONSUMER_RATE - Static variable in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
DEFAULT_HEALTHCHECK_MAX_PRODUCER_RATE - Static variable in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
DEFAULT_INTERNAL_LISTENER - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
DEFAULT_LOG_CLIENT_IP_ADDRESS - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuditLogConfig
 
DEFAULT_MAX_COMPACTION_LAG_MS_MIN - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig
 
DEFAULT_MAX_COMPACTION_LAG_MS_MIN - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
DEFAULT_MAX_MESSAGE_BYTES_MAX - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
DEFAULT_MAX_PARTITIONS_PER_TENANT - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
DEFAULT_MIN_NETWORK_BYTE_RATE - Static variable in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
DEFAULT_MULTI_TENANT_AUDIT_LOGGER_ENABLE_CONFIG - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuditLogConfig
 
DEFAULT_NETWORK_QUOTA_OVERHEAD_PERCENTAGE - Static variable in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
DEFAULT_NUM_PARTITIONS_MAX - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig
 
DEFAULT_NUM_PARTITIONS_MIN - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig
 
DEFAULT_REPLICA_SOCKET_RECEIVE_BUFFER_BYTES_MAX - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
DEFAULT_REPLICA_SOCKET_RECEIVE_BUFFER_BYTES_MIN - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
DEFAULT_REQUEST_PERCENTAGE_PER_BROKER - Static variable in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
DEFAULT_RETENTION_MS_MAX - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig
 
DEFAULT_RETENTION_MS_MAX - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
DEFAULT_RETENTION_MS_MIN - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig
 
DEFAULT_SASL_MECHANISMS_ALLOWED - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
DEFAULT_SECURITY_PROTOCOL_MAP - Static variable in class io.confluent.common.EndPoint
 
DEFAULT_SEGMENT_BYTES_MAX - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
DEFAULT_SEGMENT_BYTES_MIN - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
DEFAULT_SEGMENT_MS_MIN - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
DEFAULT_SSL_CIPHER_SUITES_ALLOWED - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig
 
DEFAULT_TOPIC_CONFIG_SYNC_MS_MAX - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
DEFAULT_TOPIC_CONFIG_SYNC_MS_MIN - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
DELETE_RETENTION_MS_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
DELETE_RETENTION_MS_MAX_CONFIG_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
deleteAcls(AuthorizableRequestContext, List<AclBindingFilter>) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
deleteAcls(AuthorizableRequestContext, List<AclBindingFilter>) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
deleteAcls(AuthorizableRequestContext, List<AclBindingFilter>, Optional<String>) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
deletedClusters() - Method in class io.confluent.kafka.multitenant.TenantLifecycleManager
Return all logical clusters that were deleted or being deleted Used for testing
deletedCredentials(MultiTenantSaslSecrets) - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecrets
 
deleteTenants() - Method in class io.confluent.kafka.multitenant.TenantLifecycleManager
 
deletionDate() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata.LifecycleMetadata
 
DELIMITER - Static variable in class io.confluent.kafka.multitenant.schema.TenantContext
 
DEPLOYMENT_ID_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
deserialize(byte[]) - Method in class io.confluent.kafka.multitenant.MultiTenantPrincipalBuilder
 
deserialize(byte[]) - Method in class io.confluent.kafka.multitenant.UserTenantPrincipalBuilder
 
DEST_METRICS_GROUP - Static variable in class io.confluent.kafka.link.ClusterLinkInterceptor
 
DESTINATION - Static variable in class io.confluent.kafka.server.plugins.policy.CreateClusterLinkPolicy
 
dispose() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer
 
DOC_MAX_PREFIX - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
DOC_MIN_PREFIX - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
DOC_SUFFIX - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 

E

EndPoint - Class in io.confluent.common
Represents a network endpoint.
EndPoint(String, int, SecurityProtocol) - Constructor for class io.confluent.common.EndPoint
 
EndPoint(String, int, ListenerName, SecurityProtocol) - Constructor for class io.confluent.common.EndPoint
 
entries() - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecrets
 
ENVIRONMENT_ID_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
environmentId() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
equalQuotaPerBrokerOrUnlimited(ClientQuotaType, int, Long) - Method in class io.confluent.kafka.multitenant.quota.QuotaConfig
 
equals(Object) - Method in class io.confluent.common.EndPoint
 
equals(Object) - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
equals(Object) - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata.LifecycleMetadata
 
equals(Object) - Method in class io.confluent.kafka.multitenant.quota.QuotaConfig
 
equals(Object) - Method in class io.confluent.kafka.multitenant.SslCertificateSpecification
 
equals(Object) - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent
 
equals(Object) - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
equals(Object) - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
equals(Object) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
evaluateResponse(byte[]) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer
 
EVENTS_METADATA_HEADER_KEY - Static variable in class io.confluent.kafka.multitenant.utils.Utils
 
EventsMetadata - Class in io.confluent.protobuf.cloud.events.v1
The metadata for Event from Events Platform.
EventsMetadata.Builder - Class in io.confluent.protobuf.cloud.events.v1
The metadata for Event from Events Platform.
EventsMetadataOrBuilder - Interface in io.confluent.protobuf.cloud.events.v1
 
EventsMetadataOuterClass - Class in io.confluent.protobuf.cloud.events.v1
 
EXTERNAL_LISTENER_PREFIX - Static variable in class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions
 
extractTenant(String) - Static method in class io.confluent.kafka.multitenant.schema.TenantContext
 
extractTenantPrefix(String) - Static method in class io.confluent.kafka.multitenant.schema.TenantContext
 

F

FAILED_AUTH_CACHE - Static variable in class io.confluent.kafka.server.plugins.auth.PlainSaslAuthenticator
 
FileBasedLoginModule - Class in io.confluent.kafka.server.plugins.auth
 
FileBasedLoginModule() - Constructor for class io.confluent.kafka.server.plugins.auth.FileBasedLoginModule
 
FileBasedPlainSaslAuthenticator - Class in io.confluent.kafka.server.plugins.auth
Authenticate users based on YAML config file which is periodically reloaded
FileBasedPlainSaslAuthenticator() - Constructor for class io.confluent.kafka.server.plugins.auth.FileBasedPlainSaslAuthenticator
 
FileBasedSaslServerFactory - Class in io.confluent.kafka.server.plugins.auth
 
FileBasedSaslServerFactory() - Constructor for class io.confluent.kafka.server.plugins.auth.FileBasedSaslServerFactory
 
FileBasedSaslServerProvider - Class in io.confluent.kafka.server.plugins.auth
 
FileBasedSaslServerProvider() - Constructor for class io.confluent.kafka.server.plugins.auth.FileBasedSaslServerProvider
 
findRule(KafkaPrincipal, Set<KafkaPrincipal>, String, Action) - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
fromProtobuf(LogicalCluster) - Static method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
fromString(String) - Static method in enum io.confluent.kafka.server.plugins.auth.SniValidationMode
 
fullUpdate(Iterator<Map.Entry<String, Integer>>) - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy
 
fullyDeletedClusters() - Method in class io.confluent.kafka.multitenant.TenantLifecycleManager
Return all logical clusters that are considered deleted and we won't try to delete again Used for testing

G

get(String, String) - Method in class io.confluent.kafka.server.plugins.auth.AuthAttemptCache
Return the hash for the [username, password] if any
get(List<AppConfigurationEntry>, Map<String, ?>) - Method in interface io.confluent.kafka.server.plugins.auth.SaslServerSupplier
 
getAccountId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string account_id = 5;
getAccountId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
string account_id = 5;
getAccountId() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
string account_id = 5;
getAccountIdBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string account_id = 5;
getAccountIdBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
string account_id = 5;
getAccountIdBytes() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
string account_id = 5;
getAction(Action, ResourcePattern, KafkaPrincipal) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
getAction(Action, ResourcePattern, KafkaPrincipal) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
getAppName() - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
The app name is a global unique name for each pipeline.
getAppName() - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
The app name is a global unique name for each pipeline.
getAppName() - Method in interface io.confluent.protobuf.cloud.events.v1.EventsMetadataOrBuilder
The app name is a global unique name for each pipeline.
getAppNameBytes() - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
The app name is a global unique name for each pipeline.
getAppNameBytes() - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
The app name is a global unique name for each pipeline.
getAppNameBytes() - Method in interface io.confluent.protobuf.cloud.events.v1.EventsMetadataOrBuilder
The app name is a global unique name for each pipeline.
getAuthorizationID() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer
 
getBackingLogicalKafkaClusterId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
backing kafka cluster for ksql/schema-registry
getBackingLogicalKafkaClusterId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
backing kafka cluster for ksql/schema-registry
getBackingLogicalKafkaClusterId() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
backing kafka cluster for ksql/schema-registry
getBackingLogicalKafkaClusterIdBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
backing kafka cluster for ksql/schema-registry
getBackingLogicalKafkaClusterIdBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
backing kafka cluster for ksql/schema-registry
getBackingLogicalKafkaClusterIdBytes() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
backing kafka cluster for ksql/schema-registry
getBootstrapBrokerForListener(String, Map<String, ?>) - Static method in class io.confluent.common.InterClusterConnection
 
getBrokerRequestPercentage() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
uint64 broker_request_percentage = 25;
getBrokerRequestPercentage() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
uint64 broker_request_percentage = 25;
getBrokerRequestPercentage() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
uint64 broker_request_percentage = 25;
getBrokerSessionUuid(Map<String, ?>) - Static method in class io.confluent.kafka.multitenant.utils.Utils
 
getConfig() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string config = 6;
getConfig() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
string config = 6;
getConfig() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
string config = 6;
getConfigBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string config = 6;
getConfigBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
string config = 6;
getConfigBytes() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
string config = 6;
getCreated() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp created = 7;
getCreated() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
.google.protobuf.Timestamp created = 7;
getCreated() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
.google.protobuf.Timestamp created = 7;
getCreatedBuilder() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp created = 7;
getCreatedOrBuilder() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp created = 7;
getCreatedOrBuilder() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
.google.protobuf.Timestamp created = 7;
getCreatedOrBuilder() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
.google.protobuf.Timestamp created = 7;
getDeactivated() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp deactivated = 9;
getDeactivated() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
.google.protobuf.Timestamp deactivated = 9;
getDeactivated() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
.google.protobuf.Timestamp deactivated = 9;
getDeactivatedBuilder() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp deactivated = 9;
getDeactivatedOrBuilder() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp deactivated = 9;
getDeactivatedOrBuilder() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
.google.protobuf.Timestamp deactivated = 9;
getDeactivatedOrBuilder() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
.google.protobuf.Timestamp deactivated = 9;
getDefaultInstance() - Static method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
getDefaultInstance() - Static method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
getDefaultInstance() - Static method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
getDefaultInstanceForType() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
 
getDefaultInstanceForType() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
getDefaultInstanceForType() - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
 
getDefaultInstanceForType() - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
getDefaultInstanceForType() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
 
getDefaultInstanceForType() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
getDeploymentId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string deployment_id = 12;
getDeploymentId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
string deployment_id = 12;
getDeploymentId() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
string deployment_id = 12;
getDeploymentIdBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string deployment_id = 12;
getDeploymentIdBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
string deployment_id = 12;
getDeploymentIdBytes() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
string deployment_id = 12;
getDescriptor() - Static method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
 
getDescriptor() - Static method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
getDescriptor() - Static method in class io.confluent.protobuf.cloud.events.v1.Common
 
getDescriptor() - Static method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
 
getDescriptor() - Static method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
getDescriptor() - Static method in class io.confluent.protobuf.cloud.events.v1.EventsMetadataOuterClass
 
getDescriptor() - Static method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
 
getDescriptor() - Static method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
getDescriptor() - Static method in class io.confluent.protobuf.cloud.events.v1.LogicalClusterOuterClass
 
getDescriptorForType() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
 
getDescriptorForType() - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
 
getDescriptorForType() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
 
getEnvironmentId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string environment_id = 17;
getEnvironmentId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
string environment_id = 17;
getEnvironmentId() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
string environment_id = 17;
getEnvironmentIdBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string environment_id = 17;
getEnvironmentIdBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
string environment_id = 17;
getEnvironmentIdBytes() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
string environment_id = 17;
getFailed() - Method in class io.confluent.kafka.server.plugins.auth.stats.AuthenticationStats
 
getFailed() - Method in interface io.confluent.kafka.server.plugins.auth.stats.AuthenticationStatsMBean
 
getId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
Actual data for the change event.
getId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
Actual data for the change event.
getId() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
Actual data for the change event.
getIdBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
Actual data for the change event.
getIdBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
Actual data for the change event.
getIdBytes() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
Actual data for the change event.
getInstance(String) - Static method in class io.confluent.kafka.multitenant.BasePhysicalClusterMetadata
 
getInstance(String) - Static method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsStore
 
getInstance() - Static method in class io.confluent.kafka.server.plugins.auth.stats.AuthenticationStats
 
getK8SClusterId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string k8s_cluster_id = 20;
getK8SClusterId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
string k8s_cluster_id = 20;
getK8SClusterId() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
string k8s_cluster_id = 20;
getK8SClusterIdBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string k8s_cluster_id = 20;
getK8SClusterIdBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
string k8s_cluster_id = 20;
getK8SClusterIdBytes() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
string k8s_cluster_id = 20;
getLastChangeId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
int64 last_change_id = 13;
getLastChangeId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
int64 last_change_id = 13;
getLastChangeId() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
int64 last_change_id = 13;
getListenerSecurityProtocol(String, Map<String, ?>) - Static method in class io.confluent.common.InterClusterConnection
 
getLogicalClusterId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
Legacy fields from cc-structs/operator/v1/logicalkafkacluster.proto
getLogicalClusterId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
Legacy fields from cc-structs/operator/v1/logicalkafkacluster.proto
getLogicalClusterId() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
Legacy fields from cc-structs/operator/v1/logicalkafkacluster.proto
getLogicalClusterIdBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
Legacy fields from cc-structs/operator/v1/logicalkafkacluster.proto
getLogicalClusterIdBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
Legacy fields from cc-structs/operator/v1/logicalkafkacluster.proto
getLogicalClusterIdBytes() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
Legacy fields from cc-structs/operator/v1/logicalkafkacluster.proto
getLogicalClusterName() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string logical_cluster_name = 19;
getLogicalClusterName() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
string logical_cluster_name = 19;
getLogicalClusterName() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
string logical_cluster_name = 19;
getLogicalClusterNameBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string logical_cluster_name = 19;
getLogicalClusterNameBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
string logical_cluster_name = 19;
getLogicalClusterNameBytes() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
string logical_cluster_name = 19;
getLogicalClusterType() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string logical_cluster_type = 21;
getLogicalClusterType() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
string logical_cluster_type = 21;
getLogicalClusterType() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
string logical_cluster_type = 21;
getLogicalClusterTypeBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string logical_cluster_type = 21;
getLogicalClusterTypeBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
string logical_cluster_type = 21;
getLogicalClusterTypeBytes() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
string logical_cluster_type = 21;
getLsn() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
DB log sequence number for the change event
getLsn() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
DB log sequence number for the change event
getLsn() - Method in interface io.confluent.protobuf.cloud.events.v1.ChangeEventMetadataOrBuilder
DB log sequence number for the change event
getMaxNetworkEgressByteRate() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
uint64 max_network_egress_byte_rate = 27;
getMaxNetworkEgressByteRate() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
uint64 max_network_egress_byte_rate = 27;
getMaxNetworkEgressByteRate() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
uint64 max_network_egress_byte_rate = 27;
getMaxNetworkIngressByteRate() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
uint64 max_network_ingress_byte_rate = 26;
getMaxNetworkIngressByteRate() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
uint64 max_network_ingress_byte_rate = 26;
getMaxNetworkIngressByteRate() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
uint64 max_network_ingress_byte_rate = 26;
getMaxPartitions() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
int32 max_partitions = 28;
getMaxPartitions() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
int32 max_partitions = 28;
getMaxPartitions() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
int32 max_partitions = 28;
getMechanismName() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer
 
getMechanismNames(Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer.PlainSaslServerFactory
 
getMetadata() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
Metadata for the change event.
getMetadata() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
Metadata for the change event.
getMetadata() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
Metadata for the change event.
getMetadataBuilder() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
Metadata for the change event.
getMetadataOrBuilder() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
Metadata for the change event.
getMetadataOrBuilder() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
Metadata for the change event.
getMetadataOrBuilder() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
Metadata for the change event.
getModified() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp modified = 8;
getModified() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
.google.protobuf.Timestamp modified = 8;
getModified() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
.google.protobuf.Timestamp modified = 8;
getModifiedBuilder() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp modified = 8;
getModifiedOrBuilder() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp modified = 8;
getModifiedOrBuilder() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
.google.protobuf.Timestamp modified = 8;
getModifiedOrBuilder() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
.google.protobuf.Timestamp modified = 8;
getName() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string name = 2;
getName() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
string name = 2;
getName() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
string name = 2;
getNameBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string name = 2;
getNameBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
string name = 2;
getNameBytes() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
string name = 2;
getNegotiatedProperty(String) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer
 
getNetworkEgressByteRate() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
uint64 network_egress_byte_rate = 24;
getNetworkEgressByteRate() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
uint64 network_egress_byte_rate = 24;
getNetworkEgressByteRate() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
uint64 network_egress_byte_rate = 24;
getNetworkIngressByteRate() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
uint64 network_ingress_byte_rate = 23;
getNetworkIngressByteRate() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
uint64 network_ingress_byte_rate = 23;
getNetworkIngressByteRate() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
uint64 network_ingress_byte_rate = 23;
getOp() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
DB operation for the change event: "c" => insert, "u"->update; "d"->delete
getOp() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
DB operation for the change event: "c" => insert, "u"->update; "d"->delete
getOp() - Method in interface io.confluent.protobuf.cloud.events.v1.ChangeEventMetadataOrBuilder
DB operation for the change event: "c" => insert, "u"->update; "d"->delete
getOpBytes() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
DB operation for the change event: "c" => insert, "u"->update; "d"->delete
getOpBytes() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
DB operation for the change event: "c" => insert, "u"->update; "d"->delete
getOpBytes() - Method in interface io.confluent.protobuf.cloud.events.v1.ChangeEventMetadataOrBuilder
DB operation for the change event: "c" => insert, "u"->update; "d"->delete
getOrganizationId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
int32 organization_id = 14;
getOrganizationId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
int32 organization_id = 14;
getOrganizationId() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
int32 organization_id = 14;
getOrgResourceId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string org_resource_id = 16;
getOrgResourceId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
string org_resource_id = 16;
getOrgResourceId() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
string org_resource_id = 16;
getOrgResourceIdBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string org_resource_id = 16;
getOrgResourceIdBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
string org_resource_id = 16;
getOrgResourceIdBytes() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
string org_resource_id = 16;
getParserForType() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
getParserForType() - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
getParserForType() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
getPhysicalClusterId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string physical_cluster_id = 3;
getPhysicalClusterId() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
string physical_cluster_id = 3;
getPhysicalClusterId() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
string physical_cluster_id = 3;
getPhysicalClusterIdBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string physical_cluster_id = 3;
getPhysicalClusterIdBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
string physical_cluster_id = 3;
getPhysicalClusterIdBytes() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
string physical_cluster_id = 3;
getScope() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent
 
getSequenceId() - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
We can't use an exactly once ordering here (yet), and thus consumers need a way to distinguish replayed messages from the most updated one.
getSequenceId() - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
We can't use an exactly once ordering here (yet), and thus consumers need a way to distinguish replayed messages from the most updated one.
getSequenceId() - Method in interface io.confluent.protobuf.cloud.events.v1.EventsMetadataOrBuilder
We can't use an exactly once ordering here (yet), and thus consumers need a way to distinguish replayed messages from the most updated one.
getSerializedSize() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
getSerializedSize() - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
getSerializedSize() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
getStatusDetail() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string status_detail = 10;
getStatusDetail() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
string status_detail = 10;
getStatusDetail() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
string status_detail = 10;
getStatusDetailBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string status_detail = 10;
getStatusDetailBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
string status_detail = 10;
getStatusDetailBytes() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
string status_detail = 10;
getStatusModified() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp status_modified = 11;
getStatusModified() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
.google.protobuf.Timestamp status_modified = 11;
getStatusModified() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
.google.protobuf.Timestamp status_modified = 11;
getStatusModifiedBuilder() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp status_modified = 11;
getStatusModifiedOrBuilder() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp status_modified = 11;
getStatusModifiedOrBuilder() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
.google.protobuf.Timestamp status_modified = 11;
getStatusModifiedOrBuilder() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
.google.protobuf.Timestamp status_modified = 11;
getStorageBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
uint64 storage_bytes = 22;
getStorageBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
uint64 storage_bytes = 22;
getStorageBytes() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
uint64 storage_bytes = 22;
getSucceeded() - Method in class io.confluent.kafka.server.plugins.auth.stats.AuthenticationStats
 
getSucceeded() - Method in interface io.confluent.kafka.server.plugins.auth.stats.AuthenticationStatsMBean
 
getText() - Method in enum io.confluent.kafka.server.plugins.auth.SniValidationMode
 
getTotal() - Method in class io.confluent.kafka.server.plugins.auth.stats.AuthenticationStats
 
getTotal() - Method in interface io.confluent.kafka.server.plugins.auth.stats.AuthenticationStatsMBean
 
getTransactionId() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
DB transaction id for the change event
getTransactionId() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
DB transaction id for the change event
getTransactionId() - Method in interface io.confluent.protobuf.cloud.events.v1.ChangeEventMetadataOrBuilder
DB transaction id for the change event
getType() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string type = 4;
getType() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
string type = 4;
getType() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
string type = 4;
getTypeBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string type = 4;
getTypeBytes() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
string type = 4;
getTypeBytes() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
string type = 4;
getUnknownFields() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
getUnknownFields() - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
getUnknownFields() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 

H

handle(Callback[]) - Method in class io.confluent.kafka.server.plugins.auth.oauth.OAuthBearerServerLoginCallbackHandler
 
handle(Callback[]) - Method in class io.confluent.kafka.server.plugins.auth.oauth.OAuthBearerValidatorCallbackHandler
 
handle(Callback[]) - Method in class io.confluent.kafka.server.plugins.auth.token.TokenBearerServerLoginCallbackHandler
 
handle(Callback[]) - Method in class io.confluent.kafka.server.plugins.auth.token.TokenBearerValidatorCallbackHandler
 
handleSocketServerInitialized(String) - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
 
handleSocketServerInitialized(String) - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
hasCreated() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp created = 7;
hasCreated() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
.google.protobuf.Timestamp created = 7;
hasCreated() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
.google.protobuf.Timestamp created = 7;
hasDeactivated() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp deactivated = 9;
hasDeactivated() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
.google.protobuf.Timestamp deactivated = 9;
hasDeactivated() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
.google.protobuf.Timestamp deactivated = 9;
hashCode() - Method in class io.confluent.common.EndPoint
 
hashCode() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
hashCode() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata.LifecycleMetadata
 
hashCode() - Method in class io.confluent.kafka.multitenant.quota.QuotaConfig
 
hashCode() - Method in class io.confluent.kafka.multitenant.SslCertificateSpecification
 
hashCode() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent
 
hashCode() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
hashCode() - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
hashCode() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
hashedSecret() - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslConfigEntry
 
hashFunction() - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslConfigEntry
 
hasMetadata() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
Metadata for the change event.
hasMetadata() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
Metadata for the change event.
hasMetadata() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
Metadata for the change event.
hasModified() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp modified = 8;
hasModified() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
.google.protobuf.Timestamp modified = 8;
hasModified() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
.google.protobuf.Timestamp modified = 8;
hasQuotaLimit(ClientQuotaType) - Method in class io.confluent.kafka.multitenant.quota.QuotaConfig
 
hasStatusModified() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp status_modified = 11;
hasStatusModified() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
.google.protobuf.Timestamp status_modified = 11;
hasStatusModified() - Method in interface io.confluent.protobuf.cloud.events.v1.LogicalClusterOrBuilder
.google.protobuf.Timestamp status_modified = 11;
hasTenantPrefix(String, String) - Static method in class io.confluent.kafka.multitenant.schema.TenantContext
 
hasTenantPrefix(String) - Method in class io.confluent.kafka.multitenant.schema.TenantContext
 
HEALTHCHECK_LOGICAL_CLUSTER_TYPE - Static variable in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
host() - Method in class io.confluent.common.EndPoint
 

I

ID_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
inactiveClusters() - Method in class io.confluent.kafka.multitenant.TenantLifecycleManager
Return all logical clusters that are deactivated
incrFailed() - Method in class io.confluent.kafka.server.plugins.auth.stats.AuthenticationStats
 
incrSucceeded() - Method in class io.confluent.kafka.server.plugins.auth.stats.AuthenticationStats
 
initialize(Subject, CallbackHandler, Map<String, ?>, Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.auth.FileBasedLoginModule
 
initialize(List<AppConfigurationEntry>) - Method in class io.confluent.kafka.server.plugins.auth.FileBasedPlainSaslAuthenticator
 
initialize() - Static method in class io.confluent.kafka.server.plugins.auth.FileBasedSaslServerProvider
 
initialize(Subject, CallbackHandler, Map<String, ?>, Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.auth.TopicBasedLoginModule
 
initialize(List<AppConfigurationEntry>) - Method in class io.confluent.kafka.server.plugins.auth.TopicBasedPlainSaslAuthenticator
 
initialize() - Static method in class io.confluent.kafka.server.plugins.auth.TopicBasedSaslServerProvider
 
INSTANCES - Static variable in class io.confluent.kafka.multitenant.BasePhysicalClusterMetadata
 
intConfig(Map<String, ?>, String) - Static method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig
 
intercept(AbstractRequest, int) - Method in class io.confluent.kafka.multitenant.MultiTenantRequestContext
 
InterClusterConnection - Class in io.confluent.common
 
InterClusterConnection() - Constructor for class io.confluent.common.InterClusterConnection
 
INTERNAL_LISTENER_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
INTERNAL_LISTENER_CONFIG_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
internalGetFieldAccessorTable() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
 
internalGetFieldAccessorTable() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
internalGetFieldAccessorTable() - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
 
internalGetFieldAccessorTable() - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
internalGetFieldAccessorTable() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
 
internalGetFieldAccessorTable() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
invalidate(String, String) - Method in class io.confluent.kafka.server.plugins.auth.AuthAttemptCache
Remove a cache entry, if it exists.
invalidCipherSuiteMessage(Collection<String>, String) - Static method in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig
 
io.confluent.common - package io.confluent.common
 
io.confluent.common.security.utils - package io.confluent.common.security.utils
 
io.confluent.kafka.link - package io.confluent.kafka.link
 
io.confluent.kafka.multitenant - package io.confluent.kafka.multitenant
 
io.confluent.kafka.multitenant.assignor - package io.confluent.kafka.multitenant.assignor
 
io.confluent.kafka.multitenant.authorizer - package io.confluent.kafka.multitenant.authorizer
 
io.confluent.kafka.multitenant.metrics - package io.confluent.kafka.multitenant.metrics
 
io.confluent.kafka.multitenant.quota - package io.confluent.kafka.multitenant.quota
 
io.confluent.kafka.multitenant.schema - package io.confluent.kafka.multitenant.schema
 
io.confluent.kafka.multitenant.utils - package io.confluent.kafka.multitenant.utils
 
io.confluent.kafka.security.audit.event - package io.confluent.kafka.security.audit.event
 
io.confluent.kafka.security.authorizer - package io.confluent.kafka.security.authorizer
 
io.confluent.kafka.security.authorizer.acl - package io.confluent.kafka.security.authorizer.acl
 
io.confluent.kafka.security.ldap.authorizer - package io.confluent.kafka.security.ldap.authorizer
 
io.confluent.kafka.server.plugins.auth - package io.confluent.kafka.server.plugins.auth
 
io.confluent.kafka.server.plugins.auth.oauth - package io.confluent.kafka.server.plugins.auth.oauth
 
io.confluent.kafka.server.plugins.auth.stats - package io.confluent.kafka.server.plugins.auth.stats
 
io.confluent.kafka.server.plugins.auth.token - package io.confluent.kafka.server.plugins.auth.token
 
io.confluent.kafka.server.plugins.policy - package io.confluent.kafka.server.plugins.policy
 
io.confluent.protobuf.cloud.events.v1 - package io.confluent.protobuf.cloud.events.v1
 
IpConnectionSensorBuilder - Class in io.confluent.kafka.multitenant.metrics
 
IpConnectionSensorBuilder(Metrics, MultiTenantPrincipal, InetAddress) - Constructor for class io.confluent.kafka.multitenant.metrics.IpConnectionSensorBuilder
 
isActive() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
isApiAllowed(ApiKeys) - Static method in class io.confluent.kafka.link.ClusterLinkApis
 
isApiAllowed(ApiKeys) - Method in class io.confluent.kafka.multitenant.schema.MultiTenantApis
Check whether an API is supported.
isAuditLogEnabled() - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
isClusterPrefixForHostnameEnabled() - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig
 
isComplete() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer
 
isExpired(Metrics, Sensor) - Static method in class io.confluent.kafka.multitenant.metrics.TenantMetrics
 
isInitialized() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
 
isInitialized() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
isInitialized() - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
 
isInitialized() - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
isInitialized() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
 
isInitialized() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
isNewTopic() - Method in class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignor.TopicInfo
 
isSchemaValidationEnabled() - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig
 
isSniHostNameMatched(OAuthBearerExtensionsValidatorCallback, String, String, SniValidationMode) - Method in class io.confluent.kafka.server.plugins.auth.oauth.OAuthBearerValidatorCallbackHandler
 
isSuperUser(KafkaPrincipal, KafkaPrincipal, Action) - Method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
isSuperUser(MultiTenantPrincipal, Action, boolean, boolean, boolean) - Static method in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
isSuperUser(KafkaPrincipal, Scope) - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
isTenantPrefixed(String) - Static method in class io.confluent.kafka.multitenant.schema.TenantContext
 
isTransformRequired(ConfigResource.Type) - Method in class io.confluent.kafka.link.LinkContext
 
isTransformRequired(ResourceType) - Method in class io.confluent.kafka.link.LinkContext
 
isTransformRequired(ResourceType) - Method in class io.confluent.kafka.multitenant.schema.TenantContext
 
isTransformRequired(ConfigResource.Type) - Method in class io.confluent.kafka.multitenant.schema.TenantContext
 
isUp() - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
Returns true if cache is loaded and listening for metadata, otherwise returns false.
isUp() - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
Returns true if cache is loaded and listening for metadata, otherwise returns false.

K

K8S_CLUSTER_ID_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
k8sClusterId() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
KAFKA_LOGICAL_CLUSTER_TYPE - Static variable in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
kafkaLogicalClusterIds() - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
 
kafkaLogicalClusterIds() - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 

L

LAST_CHANGE_ID_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
LdapAuthorizer - Class in io.confluent.kafka.security.ldap.authorizer
 
LdapAuthorizer() - Constructor for class io.confluent.kafka.security.ldap.authorizer.LdapAuthorizer
 
lifecycleMetadata() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
LifecycleMetadata(String, String, Date, Date) - Constructor for class io.confluent.kafka.multitenant.LogicalClusterMetadata.LifecycleMetadata
 
LINK_HEALTHCHECK_LOGICAL_CLUSTER_TYPE - Static variable in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
linkAdded(UUID, Optional<String>, String) - Method in class io.confluent.kafka.server.plugins.policy.CreateClusterLinkPolicy
 
LinkContext - Class in io.confluent.kafka.link
 
LinkContext(String, String, String) - Constructor for class io.confluent.kafka.link.LinkContext
 
linkDeleted(UUID) - Method in class io.confluent.kafka.server.plugins.policy.CreateClusterLinkPolicy
 
linkName() - Method in class io.confluent.kafka.link.LinkContext
 
listenerName() - Method in class io.confluent.common.EndPoint
 
load(String, long, long) - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsLoader
 
load() - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsStore
The underlying secrets entries returned by this method may be concurrently modified on API key updates.
loadKeyPair(InputStream) - Static method in class io.confluent.common.security.utils.PemUtils
 
loadPublicKey(InputStream) - Static method in class io.confluent.common.security.utils.PemUtils
 
loadSecrets() - Method in class io.confluent.kafka.server.plugins.auth.FileBasedPlainSaslAuthenticator
 
loadSecrets() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslAuthenticator
 
loadSecrets() - Method in class io.confluent.kafka.server.plugins.auth.TopicBasedPlainSaslAuthenticator
 
log - Variable in class io.confluent.kafka.server.plugins.auth.PlainSaslAuthenticator
 
LOG_CLIENT_IP_ADDRESS - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuditLogConfig
 
LOG_CLIENT_IP_ADDRESS_DOC - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuditLogConfig
 
LOGICAL_CLUSTER_ID_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
LOGICAL_CLUSTER_NAME_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
LOGICAL_CLUSTER_TYPE_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
LogicalCluster - Class in io.confluent.protobuf.cloud.events.v1
Event published by the CDC pipeline for the logical cluster table.
LogicalCluster.Builder - Class in io.confluent.protobuf.cloud.events.v1
Event published by the CDC pipeline for the logical cluster table.
logicalClusterId() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
logicalClusterId() - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslConfigEntry
 
logicalClusterIds() - Method in class io.confluent.kafka.multitenant.BasePhysicalClusterMetadata
Returns all active logical clusters with up-to-date/valid metadata hosted by this physical cluster
logicalClusterIds() - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
 
logicalClusterIds() - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
logicalClusterIdsIncludingStale() - Method in class io.confluent.kafka.multitenant.BasePhysicalClusterMetadata
Returns all active logical clusters hosted by this physical cluster, including logical clusters with stale/invalid metadata
logicalClusterIdsIncludingStale() - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
 
logicalClusterIdsIncludingStale() - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
LogicalClusterMetadata - Class in io.confluent.kafka.multitenant
Represents logical cluster metadata
LogicalClusterMetadata(String, String, String, String, String, String, Long, Long, Long, Long, Long, Long, Integer, LogicalClusterMetadata.LifecycleMetadata, Integer, String, String) - Constructor for class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
LogicalClusterMetadata.LifecycleMetadata - Class in io.confluent.kafka.multitenant
 
logicalClusterName() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata.LifecycleMetadata
 
logicalClusterName() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
LogicalClusterOrBuilder - Interface in io.confluent.protobuf.cloud.events.v1
 
LogicalClusterOuterClass - Class in io.confluent.protobuf.cloud.events.v1
 
logicalClusterType() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
login() - Method in class io.confluent.kafka.server.plugins.auth.FileBasedLoginModule
 
login() - Method in class io.confluent.kafka.server.plugins.auth.TopicBasedLoginModule
 
logout() - Method in class io.confluent.kafka.server.plugins.auth.FileBasedLoginModule
 
logout() - Method in class io.confluent.kafka.server.plugins.auth.TopicBasedLoginModule
 
LSN_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 

M

main(String[]) - Static method in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
main(String[]) - Static method in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
matchingPrincipals(KafkaPrincipal, Set<KafkaPrincipal>) - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider
 
matchingPrincipals(KafkaPrincipal, Set<KafkaPrincipal>) - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
MAX_ACLS_PER_TENANT_PROP - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
MAX_COMPACTION_LAG_MS_MIN_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig
 
MAX_COMPACTION_LAG_MS_MIN_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
MAX_DEST_LINKS_PER_TENANT_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
MAX_MESSAGE_BYTES_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
MAX_MESSAGE_BYTES_MAX_CONFIG_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
MAX_NETWORK_EGRESS_BYTE_RATE_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
MAX_NETWORK_INGRESS_BYTE_RATE_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
MAX_PARTITIONS_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
MAX_PARTITIONS_PER_TENANT_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
MAX_PARTITIONS_PER_TENANT_CONFIG_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
MAX_SOURCE_LINKS_PER_TENANT_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
maxPartitions() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
maybeBuildAssignor(Optional<KafkaPrincipal>) - Method in class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignorBuilder
Builds a #TopicReplicaAssignor to be used for replica assignment.
mayDeny() - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider
 
mayDeny() - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
mergeCreated(Timestamp) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp created = 7;
mergeDeactivated(Timestamp) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp deactivated = 9;
mergeFrom(Message) - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
 
mergeFrom(ChangeEventMetadata) - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
 
mergeFrom(Message) - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
 
mergeFrom(EventsMetadata) - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
 
mergeFrom(Message) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
 
mergeFrom(LogicalCluster) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
 
mergeMetadata(ChangeEventMetadata) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
Metadata for the change event.
mergeModified(Timestamp) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp modified = 8;
mergeStatusModified(Timestamp) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp status_modified = 11;
mergeUnknownFields(UnknownFieldSet) - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
 
mergeUnknownFields(UnknownFieldSet) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
 
metadata(String) - Method in class io.confluent.kafka.multitenant.BasePhysicalClusterMetadata
Returns metadata of a given logical cluster ID
metadata(String) - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
 
metadata(String) - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
METADATA_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
metricsGroup() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.AggregateTenantMetricsContext
 
metricsGroup() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantMetricsContext
 
MetricsRequestContext(MultiTenantPrincipal, String, ApiKeys) - Constructor for class io.confluent.kafka.multitenant.metrics.TenantMetrics.MetricsRequestContext
 
metricTags() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.AggregateTenantMetricsContext
 
metricTags() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantIpMetricsContext
 
metricTags() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantMetricsContext
 
MIN_ISR - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
mode - Variable in class io.confluent.kafka.server.plugins.auth.PlainSaslAuthenticator
 
MODIFIED_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
MULTI_TENANT_AUDIT_LOGGER_ENABLE_CONFIG - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuditLogConfig
 
MULTI_TENANT_AUDIT_LOGGER_ENABLE_CONFIG_DOC - Static variable in class io.confluent.kafka.multitenant.authorizer.MultiTenantAuditLogConfig
 
MULTITENANT_SCHEMA_VALIDATION_ENABLED_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
MULTITENANT_SCHEMA_VALIDATION_ENABLED_DEFAULT - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
MultiTenantApis - Class in io.confluent.kafka.multitenant.schema
 
MultiTenantApis(boolean) - Constructor for class io.confluent.kafka.multitenant.schema.MultiTenantApis
 
MultiTenantAuditLogConfig - Class in io.confluent.kafka.multitenant.authorizer
 
MultiTenantAuditLogConfig(Map<String, ?>) - Constructor for class io.confluent.kafka.multitenant.authorizer.MultiTenantAuditLogConfig
 
MultiTenantAuthorizer - Class in io.confluent.kafka.multitenant.authorizer
 
MultiTenantAuthorizer() - Constructor for class io.confluent.kafka.multitenant.authorizer.MultiTenantAuthorizer
 
MultiTenantConfigRestrictions - Class in io.confluent.kafka.multitenant
 
MultiTenantConfigRestrictions() - Constructor for class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions
 
MultiTenantInterceptor - Class in io.confluent.kafka.multitenant
 
MultiTenantInterceptor() - Constructor for class io.confluent.kafka.multitenant.MultiTenantInterceptor
 
MultiTenantInterceptor(Time) - Constructor for class io.confluent.kafka.multitenant.MultiTenantInterceptor
 
MultiTenantInterceptorConfig - Class in io.confluent.kafka.multitenant
 
MultiTenantInterceptorConfig(Map<String, ?>) - Constructor for class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig
 
MultiTenantPrincipalBuilder - Class in io.confluent.kafka.multitenant
Principal builder that returns a MultiTenantPrincipal if tenant id is available.
MultiTenantPrincipalBuilder() - Constructor for class io.confluent.kafka.multitenant.MultiTenantPrincipalBuilder
 
MultiTenantRequestContext - Class in io.confluent.kafka.multitenant
 
MultiTenantRequestContext(RequestHeader, String, InetAddress, MultiTenantPrincipal, ListenerName, SecurityProtocol, ClientInformation, PathAwareSniHostName, Time, Metrics, TenantMetrics, MultiTenantInterceptorConfig, Optional<ClusterLinkSourceMetrics>, boolean, Optional<KafkaPrincipalSerde>) - Constructor for class io.confluent.kafka.multitenant.MultiTenantRequestContext
 
MultiTenantSaslConfigEntry - Class in io.confluent.kafka.server.plugins.auth
 
MultiTenantSaslConfigEntry(String, String, String, String, String, boolean, String) - Constructor for class io.confluent.kafka.server.plugins.auth.MultiTenantSaslConfigEntry
 
MultiTenantSaslSecrets - Class in io.confluent.kafka.server.plugins.auth
 
MultiTenantSaslSecrets(Map<String, MultiTenantSaslConfigEntry>) - Constructor for class io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecrets
 
MultiTenantSaslSecretsLoader - Class in io.confluent.kafka.server.plugins.auth
This class loads and caches SASL secrets from a JSON file stored on the local filesystem.
MultiTenantSaslSecretsLoader(int) - Constructor for class io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsLoader
 
MultiTenantSaslSecretsStore - Class in io.confluent.kafka.server.plugins.auth
This class loads SASL secrets from the topic _confluent-apikey.
MultiTenantSaslSecretsStore(Map<String, Object>, Metrics) - Constructor for class io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsStore
 
MultiTenantSaslSecretsStore.State - Enum in io.confluent.kafka.server.plugins.auth
The SecretsStore state.
MultiTenantSaslServer - Interface in io.confluent.kafka.multitenant
 

N

NAME_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
NETWORK_EGRESS_BYTE_RATE_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
NETWORK_INGRESS_BYTE_RATE_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
networkQuotaOverhead() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
newBuilder() - Static method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
newBuilder(ChangeEventMetadata) - Static method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
newBuilder() - Static method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
newBuilder(EventsMetadata) - Static method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
newBuilder() - Static method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
newBuilder(LogicalCluster) - Static method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
newBuilderForType() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
newBuilderForType() - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
newBuilderForType() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
newBuilderForType(GeneratedMessageV3.BuilderParent) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
newContext(RequestHeader, String, InetAddress, KafkaPrincipal, ListenerName, SecurityProtocol, ClientInformation, Metrics, PathAwareSniHostName, boolean, Optional<KafkaPrincipalSerde>) - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptor
 
newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
newInstance(GeneratedMessageV3.UnusedPrivateParameter) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
NotTenantPrefixedException(String) - Constructor for exception io.confluent.kafka.multitenant.utils.TenantSanitizer.NotTenantPrefixedException
 
NUM_PARTITIONS_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig
 
NUM_PARTITIONS_MIN_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig
 

O

OAuthBearerServerLoginCallbackHandler - Class in io.confluent.kafka.server.plugins.auth.oauth
A CallbackHandler for the OAuthLoginModule of a Kafka Broker.
OAuthBearerServerLoginCallbackHandler() - Constructor for class io.confluent.kafka.server.plugins.auth.oauth.OAuthBearerServerLoginCallbackHandler
 
OAuthBearerValidatorCallbackHandler - Class in io.confluent.kafka.server.plugins.auth.oauth
A CallbackHandler that recognizes OAuthBearerValidatorCallback and OAuthBearerExtensionsValidatorCallback for validating a secured OAuth 2 bearer token issued by Confluent and SASL extensions specifying the logical cluster this token is meant for.
OAuthBearerValidatorCallbackHandler() - Constructor for class io.confluent.kafka.server.plugins.auth.oauth.OAuthBearerValidatorCallbackHandler
 
onAuthenticatedConnection(String, InetAddress, KafkaPrincipal, Metrics) - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptor
 
onAuthenticatedDisconnection(String, InetAddress, KafkaPrincipal, Metrics) - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptor
 
OP_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
operation(AclOperation) - Static method in class io.confluent.kafka.security.authorizer.acl.AclMapper
 
ORG_RESOURCE_ID_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
ORGANIZATION_ID_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
organizationId() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 

P

parse(String) - Static method in class io.confluent.common.EndPoint
 
parse(String, Map<ListenerName, SecurityProtocol>) - Static method in class io.confluent.common.EndPoint
 
parseDelimitedFrom(InputStream) - Static method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
parseDelimitedFrom(InputStream) - Static method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
parseDelimitedFrom(InputStream) - Static method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - Static method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
parseFrom(ByteBuffer) - Static method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
parseFrom(ByteString) - Static method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
parseFrom(byte[]) - Static method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
parseFrom(InputStream) - Static method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
parseFrom(CodedInputStream) - Static method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
parseFrom(ByteBuffer) - Static method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
parseFrom(ByteString) - Static method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
parseFrom(byte[]) - Static method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
parseFrom(InputStream) - Static method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
parseFrom(CodedInputStream) - Static method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
parseFrom(ByteBuffer) - Static method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
parseFrom(ByteBuffer, ExtensionRegistryLite) - Static method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
parseFrom(ByteString) - Static method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
parseFrom(ByteString, ExtensionRegistryLite) - Static method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
parseFrom(byte[]) - Static method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
parseFrom(byte[], ExtensionRegistryLite) - Static method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
parseFrom(InputStream) - Static method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
parseFrom(InputStream, ExtensionRegistryLite) - Static method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
parseFrom(CodedInputStream) - Static method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - Static method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
parseList(Map<String, String>, String) - Method in class io.confluent.kafka.server.plugins.policy.AbstractPolicyConfig
 
parseLong(String) - Method in class io.confluent.kafka.server.plugins.policy.AbstractPolicyConfig
 
parser() - Static method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
parser() - Static method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
parser() - Static method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
parseRequest(ByteBuffer) - Method in class io.confluent.kafka.multitenant.MultiTenantRequestContext
 
parseResponse(ByteBuffer, RequestHeader, long, long) - Method in class io.confluent.kafka.link.ClusterLinkInterceptor
 
partialUpdate(String, int) - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy
 
PartitionSensorBuilder - Class in io.confluent.kafka.multitenant.metrics
 
PartitionSensorBuilder(Metrics, TenantMetrics.MetricsRequestContext) - Constructor for class io.confluent.kafka.multitenant.metrics.PartitionSensorBuilder
 
PartitionSensors - Class in io.confluent.kafka.multitenant.metrics
 
PartitionSensors(TenantMetrics.MetricsRequestContext, Metrics, PartitionSensorBuilder) - Constructor for class io.confluent.kafka.multitenant.metrics.PartitionSensors
 
PemUtils - Class in io.confluent.common.security.utils
 
PemUtils() - Constructor for class io.confluent.common.security.utils.PemUtils
 
permissionType(AclPermissionType) - Static method in class io.confluent.kafka.security.authorizer.acl.AclMapper
 
PHYSICAL_CLUSTER_ID_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
physicalClusterId() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
PhysicalClusterMetadata - Class in io.confluent.kafka.multitenant
This holds metadata passed from CCloud related to this physical cluster
PhysicalClusterMetadata(Metrics) - Constructor for class io.confluent.kafka.multitenant.PhysicalClusterMetadata
 
PhysicalClusterMetadata(Metrics, Time) - Constructor for class io.confluent.kafka.multitenant.PhysicalClusterMetadata
 
PhysicalClusterMetadata.State - Enum in io.confluent.kafka.multitenant
 
physicalK8sNamespace() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata.LifecycleMetadata
 
PLAIN_MECHANISM - Static variable in class io.confluent.kafka.server.plugins.auth.PlainSaslServer
 
PlainSaslAuthenticator - Class in io.confluent.kafka.server.plugins.auth
 
PlainSaslAuthenticator(AuthAttemptCache, AuthAttemptCache) - Constructor for class io.confluent.kafka.server.plugins.auth.PlainSaslAuthenticator
 
PlainSaslServer - Class in io.confluent.kafka.server.plugins.auth
SaslServer implementation for SASL/PLAIN with an authenticator provided through the constructor.
PlainSaslServer(List<AppConfigurationEntry>, SaslAuthenticator) - Constructor for class io.confluent.kafka.server.plugins.auth.PlainSaslServer
 
PlainSaslServer(List<AppConfigurationEntry>, SaslAuthenticator, PathAwareSniHostName) - Constructor for class io.confluent.kafka.server.plugins.auth.PlainSaslServer
 
PlainSaslServer.PlainSaslServerFactory - Class in io.confluent.kafka.server.plugins.auth
 
PlainSaslServerFactory(SaslServerSupplier) - Constructor for class io.confluent.kafka.server.plugins.auth.PlainSaslServer.PlainSaslServerFactory
 
PolicyUtils - Class in io.confluent.kafka.server.plugins.policy
 
port() - Method in class io.confluent.common.EndPoint
 
prefix - Variable in class io.confluent.kafka.multitenant.schema.TenantContext
 
prefix() - Method in class io.confluent.kafka.multitenant.schema.TenantContext
 
prefixedWildcard() - Method in class io.confluent.kafka.multitenant.schema.TenantContext
 
prefixSizeInBytes - Variable in class io.confluent.kafka.multitenant.schema.TenantContext
 
prefixSizeInBytes() - Method in class io.confluent.kafka.multitenant.schema.TenantContext
 
prependExternalListenerToConfigName(String) - Static method in class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions
Return an empty Optional if `configName` is not an updatable listener config name, otherwise return the config name with `EXTERNAL_LISTENER_PREFIX` prepended within the Optional.
principal() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantMetricsContext
 
principal - Variable in class io.confluent.kafka.multitenant.schema.TenantContext
 
principal() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent
 
producerByteRate() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
providerName() - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider
 
providerName() - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
put(String, String, String) - Method in class io.confluent.kafka.server.plugins.auth.AuthAttemptCache
Cache an authorisation.

Q

quota(ClientQuotaType) - Method in class io.confluent.kafka.multitenant.quota.QuotaConfig
 
quotaConfig() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
QuotaConfig - Class in io.confluent.kafka.multitenant.quota
 
QuotaConfig(Long, Long, Double, Double, QuotaConfig) - Constructor for class io.confluent.kafka.multitenant.quota.QuotaConfig
 
quotaLimit(ClientQuotaType, Map<String, String>) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
 
quotaMetricTags(ClientQuotaType, KafkaPrincipal, String) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
 
quotaResetRequired(ClientQuotaType) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
 

R

rackForBroker(int) - Method in interface io.confluent.kafka.multitenant.assignor.RackMetadata
 
RackMetadata - Interface in io.confluent.kafka.multitenant.assignor
 
read(EntityType, String) - Method in class io.confluent.kafka.link.LinkContext
 
read(EntityType, Message) - Method in class io.confluent.kafka.link.LinkContext
 
read(EntityType, String) - Method in class io.confluent.kafka.multitenant.schema.TenantContext
 
read(EntityType, Message) - Method in class io.confluent.kafka.multitenant.schema.TenantContext
 
reconfigurableConfigs() - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
 
reconfigurableConfigs() - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
reconfigurableConfigs() - Method in class io.confluent.kafka.server.plugins.policy.CreateClusterLinkPolicy
 
reconfigurableConfigs() - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy
 
reconfigure(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
 
reconfigure(Map<String, ?>) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
reconfigure(Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.policy.CreateClusterLinkPolicy
 
reconfigure(Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy
 
recordAuthenticatedConnection() - Method in class io.confluent.kafka.multitenant.metrics.ConnectionSensors
 
recordAuthenticatedConnection(Metrics, MultiTenantPrincipal, InetAddress) - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics
 
recordAuthenticatedDisconnection() - Method in class io.confluent.kafka.multitenant.metrics.ConnectionSensors
 
recordAuthenticatedDisconnection() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics
 
recordPartitionStatsIn(Metrics, TenantMetrics.MetricsRequestContext, TopicPartition, int, int, long) - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics
 
recordPartitionStatsOut(Metrics, TenantMetrics.MetricsRequestContext, TopicPartition, int, int, long) - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics
 
recordRequest(Metrics, TenantMetrics.MetricsRequestContext, long, long) - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics
 
recordResponse(Metrics, TenantMetrics.MetricsRequestContext, long, long, Map<Errors, Integer>, long) - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics
 
recordStatsIn(TopicPartition, long, long, long) - Method in class io.confluent.kafka.multitenant.metrics.PartitionSensors
 
recordStatsOut(TopicPartition, long, long, long) - Method in class io.confluent.kafka.multitenant.metrics.PartitionSensors
 
registerAllExtensions(ExtensionRegistryLite) - Static method in class io.confluent.protobuf.cloud.events.v1.Common
 
registerAllExtensions(ExtensionRegistry) - Static method in class io.confluent.protobuf.cloud.events.v1.Common
 
registerAllExtensions(ExtensionRegistryLite) - Static method in class io.confluent.protobuf.cloud.events.v1.EventsMetadataOuterClass
 
registerAllExtensions(ExtensionRegistry) - Static method in class io.confluent.protobuf.cloud.events.v1.EventsMetadataOuterClass
 
registerAllExtensions(ExtensionRegistryLite) - Static method in class io.confluent.protobuf.cloud.events.v1.LogicalClusterOuterClass
 
registerAllExtensions(ExtensionRegistry) - Static method in class io.confluent.protobuf.cloud.events.v1.LogicalClusterOuterClass
 
registerMetrics(Metrics) - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy
 
removeAllTenantPrefixes(String) - Method in class io.confluent.kafka.multitenant.schema.TenantContext
 
removePrefix(String) - Static method in class io.confluent.kafka.multitenant.schema.TenantContext
 
removeQuota(ClientQuotaType, ClientQuotaEntity) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
 
removeTenantPrefix(TopicPartition) - Method in class io.confluent.kafka.multitenant.schema.TenantContext
 
removeTenantPrefix(String) - Method in class io.confluent.kafka.multitenant.schema.TenantContext
 
REPLICA_SOCKET_RECEIVE_BUFFER_BYTES_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
REPLICA_SOCKET_RECEIVE_BUFFER_BYTES_MAX_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
REPLICA_SOCKET_RECEIVE_BUFFER_BYTES_MIN_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
REPLICA_SOCKET_RECEIVE_BUFFER_BYTES_MIN_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
REPLICATION_FACTOR_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
REPLICATION_FACTOR_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
replicationFactor() - Method in class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignor.TopicInfo
 
reset() - Method in class io.confluent.kafka.server.plugins.auth.stats.AuthenticationStats
 
resolvedAddress() - Method in class io.confluent.common.EndPoint
 
resourceType(ResourceType) - Static method in class io.confluent.kafka.security.authorizer.acl.AclMapper
 
restrictTopicConfigs(Map<String, String>) - Method in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
RETENTION_MS_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig
 
RETENTION_MS_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
RETENTION_MS_MAX_CONFIG_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
RETENTION_MS_MIN_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig
 

S

SASL_MECHANISMS_ALLOWED_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
SASL_MECHANISMS_ALLOWED_CONFIG_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
saslMechanism() - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslConfigEntry
 
SaslServerSupplier - Interface in io.confluent.kafka.server.plugins.auth
 
sbcApisEnabled() - Method in class io.confluent.kafka.multitenant.MultiTenantInterceptorConfig
Denotes whether the SBC APIs (like ConfluentAdmin.removeBrokers(List)) will be allowed through the interceptor
scope(MultiTenantPrincipal) - Static method in class io.confluent.kafka.multitenant.utils.TenantUtils
 
securityProtocol() - Method in class io.confluent.common.EndPoint
 
SEGMENT_BYTES_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
SEGMENT_BYTES_MAX_CONFIG_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
SEGMENT_BYTES_MIN_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
SEGMENT_BYTES_MIN_CONFIG_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
SEGMENT_MS_MIN_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
SEGMENT_MS_MIN_CONFIG_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
sensorCreators() - Method in class io.confluent.kafka.multitenant.metrics.ConnectionSensorBuilder
 
sensorCreators() - Method in class io.confluent.kafka.multitenant.metrics.IpConnectionSensorBuilder
 
sensorCreators() - Method in class io.confluent.kafka.multitenant.metrics.PartitionSensorBuilder
 
sensorSuffix(String, TenantMetrics.TenantMetricsContext) - Method in class io.confluent.kafka.multitenant.metrics.AbstractConnectionSensorBuilder
 
sensorSuffix(String, TenantMetrics.MetricsRequestContext) - Method in class io.confluent.kafka.multitenant.metrics.PartitionSensorBuilder
 
sensorSuffix() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.AggregateTenantMetricsContext
 
sensorSuffix() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantIpMetricsContext
 
sensorSuffix() - Method in class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantMetricsContext
 
SEQUENCE_ID_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
SEQUENCE_ID_STRING_HEADER_KEY - Static variable in class io.confluent.kafka.multitenant.utils.Utils
 
serialize(KafkaPrincipal) - Method in class io.confluent.kafka.multitenant.MultiTenantPrincipalBuilder
 
serialize(KafkaPrincipal) - Method in class io.confluent.kafka.multitenant.UserTenantPrincipalBuilder
 
serviceAccount() - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslConfigEntry
 
setAccountId(String) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string account_id = 5;
setAccountIdBytes(ByteString) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string account_id = 5;
setAppName(String) - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
The app name is a global unique name for each pipeline.
setAppNameBytes(ByteString) - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
The app name is a global unique name for each pipeline.
setBackingLogicalKafkaClusterId(String) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
backing kafka cluster for ksql/schema-registry
setBackingLogicalKafkaClusterIdBytes(ByteString) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
backing kafka cluster for ksql/schema-registry
setBrokerRequestPercentage(long) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
uint64 broker_request_percentage = 25;
setConfig(String) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string config = 6;
setConfigBytes(ByteString) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string config = 6;
setCreated(Timestamp) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp created = 7;
setCreated(Timestamp.Builder) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp created = 7;
setDeactivated(Timestamp) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp deactivated = 9;
setDeactivated(Timestamp.Builder) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp deactivated = 9;
setDeploymentId(String) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string deployment_id = 12;
setDeploymentIdBytes(ByteString) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string deployment_id = 12;
setEnvironmentId(String) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string environment_id = 17;
setEnvironmentIdBytes(ByteString) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string environment_id = 17;
setField(Descriptors.FieldDescriptor, Object) - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
 
setField(Descriptors.FieldDescriptor, Object) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
 
setId(String) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
Actual data for the change event.
setIdBytes(ByteString) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
Actual data for the change event.
setK8SClusterId(String) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string k8s_cluster_id = 20;
setK8SClusterIdBytes(ByteString) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string k8s_cluster_id = 20;
setLastChangeId(long) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
int64 last_change_id = 13;
setLogicalClusterId(String) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
Legacy fields from cc-structs/operator/v1/logicalkafkacluster.proto
setLogicalClusterIdBytes(ByteString) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
Legacy fields from cc-structs/operator/v1/logicalkafkacluster.proto
setLogicalClusterName(String) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string logical_cluster_name = 19;
setLogicalClusterNameBytes(ByteString) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string logical_cluster_name = 19;
setLogicalClusterType(String) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string logical_cluster_type = 21;
setLogicalClusterTypeBytes(ByteString) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string logical_cluster_type = 21;
setLsn(long) - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
DB log sequence number for the change event
setMaxNetworkEgressByteRate(long) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
uint64 max_network_egress_byte_rate = 27;
setMaxNetworkIngressByteRate(long) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
uint64 max_network_ingress_byte_rate = 26;
setMaxPartitions(int) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
int32 max_partitions = 28;
setMetadata(ChangeEventMetadata) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
Metadata for the change event.
setMetadata(ChangeEventMetadata.Builder) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
Metadata for the change event.
setModified(Timestamp) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp modified = 8;
setModified(Timestamp.Builder) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp modified = 8;
setName(String) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string name = 2;
setNameBytes(ByteString) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string name = 2;
setNetworkEgressByteRate(long) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
uint64 network_egress_byte_rate = 24;
setNetworkIngressByteRate(long) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
uint64 network_ingress_byte_rate = 23;
setOp(String) - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
DB operation for the change event: "c" => insert, "u"->update; "d"->delete
setOpBytes(ByteString) - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
DB operation for the change event: "c" => insert, "u"->update; "d"->delete
setOrganizationId(int) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
int32 organization_id = 14;
setOrgResourceId(String) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string org_resource_id = 16;
setOrgResourceIdBytes(ByteString) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string org_resource_id = 16;
setPhysicalClusterId(String) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string physical_cluster_id = 3;
setPhysicalClusterIdBytes(ByteString) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string physical_cluster_id = 3;
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
 
setRepeatedField(Descriptors.FieldDescriptor, int, Object) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
 
setSequenceId(long) - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
We can't use an exactly once ordering here (yet), and thus consumers need a way to distinguish replayed messages from the most updated one.
setStatusDetail(String) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string status_detail = 10;
setStatusDetailBytes(ByteString) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string status_detail = 10;
setStatusModified(Timestamp) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp status_modified = 11;
setStatusModified(Timestamp.Builder) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
.google.protobuf.Timestamp status_modified = 11;
setStorageBytes(long) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
uint64 storage_bytes = 22;
setTransactionId(long) - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
DB transaction id for the change event
setType(String) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string type = 4;
setTypeBytes(ByteString) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
string type = 4;
setUnknownFields(UnknownFieldSet) - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata.Builder
 
setUnknownFields(UnknownFieldSet) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster.Builder
 
shouldIntercept() - Method in class io.confluent.kafka.multitenant.MultiTenantRequestContext
 
sizeOfRemovedPrefixes(String) - Method in class io.confluent.kafka.multitenant.schema.TenantContext
 
SNI_HOST_NAME_VALIDATION_MODE_KEY - Static variable in enum io.confluent.kafka.server.plugins.auth.SniValidationMode
 
sniHostNameMatches(String, Optional<String>, Optional<PathAwareSniHostName>) - Method in enum io.confluent.kafka.server.plugins.auth.SniValidationMode
Validate if the supplied cluster Id matches with the ground truth.
SniValidationMode - Enum in io.confluent.kafka.server.plugins.auth
Enum class that represents different mode of SNI host name validation in the authenticator.
SOURCE - Static variable in class io.confluent.kafka.server.plugins.policy.CreateClusterLinkPolicy
 
SOURCE_METRICS_GROUP - Static variable in class io.confluent.kafka.link.ClusterLinkInterceptor
 
SSL_CIPHER_SUITES_ALLOWED_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig
 
sslCertificateManager - Variable in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
 
SslCertificateManager - Class in io.confluent.kafka.multitenant
 
sslCertificateManager - Variable in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
SslCertificateSpecification - Class in io.confluent.kafka.multitenant
Represents specifications for ssl certificates - pem and pkcs
start(Map<String, Object>, Collection<Endpoint>) - Method in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
 
start(Map<String, Object>, Collection<Endpoint>) - Method in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
start(ConfluentAuthorizerServerInfo, Map<String, ?>) - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
start(AuthorizerServerInfo) - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
start(AuthorizerServerInfo) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
start(Collection<Endpoint>) - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsStore
 
status() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent
 
STATUS_DETAIL_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
STATUS_MODIFIED_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
STORAGE_BYTES_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
storageBytes() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
stripExternalListenerPrefixFromConfigName(String) - Static method in class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions
Return an empty Optional if `configName` is not an updatable external listener config name, otherwise return the config name with `EXTERNAL_LISTENER_PREFIX` stripped within the Optional.
SUCCESSFUL_AUTH_CACHE - Static variable in class io.confluent.kafka.server.plugins.auth.PlainSaslAuthenticator
 

T

TenantAclProvider - Class in io.confluent.kafka.multitenant.authorizer
Multi-tenant authorizer that supports: ACLs with TenantUser:clusterId_userId as principal ACLs with TenantUser*:clusterId_ as wildcard prefixed principal ACLs with User:* as wildcard principal (e.g.
TenantAclProvider() - Constructor for class io.confluent.kafka.multitenant.authorizer.TenantAclProvider
 
tenantAuditEvent(AuditEvent, String) - Static method in class io.confluent.kafka.multitenant.utils.TenantSanitizer
 
tenantAuditEvent(AuditEvent) - Static method in class io.confluent.kafka.multitenant.utils.TenantSanitizer
 
TenantContext - Class in io.confluent.kafka.multitenant.schema
This class contains the core logic to transform Kafka requests and responses so that topics/groups/etc have appropriate tenant prefixes.
TenantContext(MultiTenantPrincipal) - Constructor for class io.confluent.kafka.multitenant.schema.TenantContext
 
TenantIpMetricsContext(MultiTenantPrincipal, InetAddress) - Constructor for class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantIpMetricsContext
 
tenantLifecycleManager - Variable in class io.confluent.kafka.multitenant.PhysicalClusterMetadata
 
TenantLifecycleManager - Class in io.confluent.kafka.multitenant
 
TenantLifecycleManager(Map<String, ?>) - Constructor for class io.confluent.kafka.multitenant.TenantLifecycleManager
 
tenantLifecycleManager - Variable in class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
tenantMetadata() - Method in interface io.confluent.kafka.multitenant.MultiTenantSaslServer
 
tenantMetadata() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer
 
TenantMetrics - Class in io.confluent.kafka.multitenant.metrics
 
TenantMetrics() - Constructor for class io.confluent.kafka.multitenant.metrics.TenantMetrics
 
TenantMetrics.AggregateTenantMetricsContext - Class in io.confluent.kafka.multitenant.metrics
See: CNK-1347 Currently, the request metrics tracked by the metrics API (Telemetry reporter) and what DataDog charts track internally are not equivalent.
TenantMetrics.MetricsRequestContext - Class in io.confluent.kafka.multitenant.metrics
 
TenantMetrics.TenantIpMetricsContext - Class in io.confluent.kafka.multitenant.metrics
 
TenantMetrics.TenantMetricsContext - Class in io.confluent.kafka.multitenant.metrics
 
TenantMetricsContext(MultiTenantPrincipal) - Constructor for class io.confluent.kafka.multitenant.metrics.TenantMetrics.TenantMetricsContext
 
TenantPartitionAssignor - Class in io.confluent.kafka.multitenant.assignor
Tenant partition assignor that attempts to balance tenant partitions across available brokers to ensure that quotas allocated to the broker per-partition can be fully utilized without overloading brokers.
TenantPartitionAssignor(Cluster, String, int) - Constructor for class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignor
 
TenantPartitionAssignor.TopicInfo - Class in io.confluent.kafka.multitenant.assignor
Topic details from new topic or partition create request.
TenantPartitionAssignorBuilder - Class in io.confluent.kafka.multitenant.assignor
 
TenantPartitionAssignorBuilder() - Constructor for class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignorBuilder
 
tenantPrefix() - Method in class io.confluent.kafka.multitenant.MultiTenantRequestContext
 
TenantQuotaCallback - Class in io.confluent.kafka.multitenant.quota
 
TenantQuotaCallback() - Constructor for class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
 
TenantSanitizer - Class in io.confluent.kafka.multitenant.utils
These functions transform various pieces of internal information to remove internal implementation details.
TenantSanitizer() - Constructor for class io.confluent.kafka.multitenant.utils.TenantSanitizer
 
TenantSanitizer.NotTenantPrefixedException - Exception in io.confluent.kafka.multitenant.utils
 
TenantUtils - Class in io.confluent.kafka.multitenant.utils
 
TenantUtils() - Constructor for class io.confluent.kafka.multitenant.utils.TenantUtils
 
timestamp() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent
 
toBuilder() - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
toBuilder() - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
toBuilder() - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 
TokenBearerServerLoginCallbackHandler - Class in io.confluent.kafka.server.plugins.auth.token
An abstract CallbackHandler for the OAuthLoginModule.
TokenBearerServerLoginCallbackHandler() - Constructor for class io.confluent.kafka.server.plugins.auth.token.TokenBearerServerLoginCallbackHandler
 
TokenBearerValidatorCallbackHandler - Class in io.confluent.kafka.server.plugins.auth.token
A CallbackHandler that recognizes TokenBearerValidatorCallbackHandler for validating a Authentication Tokens issued by Confluent.
TokenBearerValidatorCallbackHandler() - Constructor for class io.confluent.kafka.server.plugins.auth.token.TokenBearerValidatorCallbackHandler
 
TOPIC_CONFIG_SYNC_MS_MAX_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
TOPIC_CONFIG_SYNC_MS_MAX_CONFIG_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
TOPIC_CONFIG_SYNC_MS_MIN_CONFIG - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
TOPIC_CONFIG_SYNC_MS_MIN_CONFIG_DOC - Static variable in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
TOPIC_PREFIX - Static variable in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
TopicBasedLoginModule - Class in io.confluent.kafka.server.plugins.auth
 
TopicBasedLoginModule() - Constructor for class io.confluent.kafka.server.plugins.auth.TopicBasedLoginModule
 
TopicBasedPhysicalClusterMetadata - Class in io.confluent.kafka.multitenant
This holds metadata passed from CCloud related to this physical cluster
TopicBasedPhysicalClusterMetadata(Metrics) - Constructor for class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
TopicBasedPhysicalClusterMetadata(Metrics, Time) - Constructor for class io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata
 
TopicBasedPhysicalClusterMetadata.State - Enum in io.confluent.kafka.multitenant
 
TopicBasedPlainSaslAuthenticator - Class in io.confluent.kafka.server.plugins.auth
 
TopicBasedPlainSaslAuthenticator(Map<String, ?>) - Constructor for class io.confluent.kafka.server.plugins.auth.TopicBasedPlainSaslAuthenticator
 
TopicBasedSaslServerFactory - Class in io.confluent.kafka.server.plugins.auth
 
TopicBasedSaslServerFactory() - Constructor for class io.confluent.kafka.server.plugins.auth.TopicBasedSaslServerFactory
 
TopicBasedSaslServerProvider - Class in io.confluent.kafka.server.plugins.auth
 
TopicBasedSaslServerProvider() - Constructor for class io.confluent.kafka.server.plugins.auth.TopicBasedSaslServerProvider
 
TopicInfo(int, short, int) - Constructor for class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignor.TopicInfo
 
TopicPolicyConfig - Class in io.confluent.kafka.server.plugins.policy
 
TopicPolicyConfig(Map<String, ?>) - Constructor for class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
toSend(RequestHeader, AbstractRequest, long) - Method in class io.confluent.kafka.link.ClusterLinkInterceptor
 
toString() - Method in class io.confluent.common.EndPoint
 
toString() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata.LifecycleMetadata
 
toString() - Method in class io.confluent.kafka.multitenant.LogicalClusterMetadata
 
toString() - Method in class io.confluent.kafka.multitenant.quota.QuotaConfig
 
toString() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent
 
toString() - Method in class io.confluent.kafka.server.plugins.auth.stats.AuthenticationStats
 
totalPartitions() - Method in class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignor.TopicInfo
 
TRANSACTION_ID_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
transformDestToSource(DescribeConfigsRequestData.DescribeConfigsResource) - Method in class io.confluent.kafka.link.LinkContext
 
transformSourceToDest(DescribeConfigsResponseData.DescribeConfigsResult) - Method in class io.confluent.kafka.link.LinkContext
 
tryParseEventsSequenceId(ConsumerRecord) - Static method in class io.confluent.kafka.multitenant.utils.Utils
Reads the header of a message produced by the events pipeline, and returns the sequence id embedded in it.
type() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent
 
TYPE_FIELD_NUMBER - Static variable in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 

U

unknownField(String, Object) - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslConfigEntry
 
UNLIMITED_QUOTA - Static variable in class io.confluent.kafka.multitenant.quota.QuotaConfig
 
unwrap(byte[], int, int) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer
 
UPDATABLE_BROKER_CONFIGS - Static variable in class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions
 
UPDATABLE_CLUSTER_LINK_CONFIGS - Static variable in class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions
 
updatableTopicConfig(String, boolean) - Static method in class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions
 
updateCache(ResourcePattern, AclAuthorizer.VersionedAcls) - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
updateClusterMetadata(Cluster) - Method in class io.confluent.kafka.multitenant.assignor.TenantPartitionAssignorBuilder
 
updateClusterMetadata(Cluster) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
Handle metadata update.
updateDynamicQuotas(Map<String, Map<String, Long>>) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
 
updateMaxPartitionsIfNecessary(LogicalClusterMetadata, LogicalClusterMetadata) - Method in class io.confluent.kafka.multitenant.TenantLifecycleManager
 
updateQuota(ClientQuotaType, ClientQuotaEntity, double) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
 
updateQuotas(Map<String, QuotaConfig>, QuotaConfig) - Static method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
Update provisioned tenant quota configuration and/or default tenant quota.
updateSecrets(ConsumerRecord<String, String>, long) - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsStore
 
updateTenantState(LogicalClusterMetadata) - Method in class io.confluent.kafka.multitenant.TenantLifecycleManager
 
updateUserQuotas(String, Map<String, QuotaConfig>, QuotaConfig) - Static method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
 
userId() - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslConfigEntry
 
userIdentifier() - Method in interface io.confluent.kafka.multitenant.MultiTenantSaslServer
 
userIdentifier() - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer
 
userPrincipal(KafkaPrincipal) - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
userResourceId(OAuthBearerJwsToken) - Method in class io.confluent.kafka.multitenant.MultiTenantPrincipalBuilder
 
userResourceId() - Method in class io.confluent.kafka.server.plugins.auth.MultiTenantSaslConfigEntry
 
UserTenantPrincipalBuilder - Class in io.confluent.kafka.multitenant
Each user has its own tenant id and namespace.
UserTenantPrincipalBuilder() - Constructor for class io.confluent.kafka.multitenant.UserTenantPrincipalBuilder
 
usesMetadataFromThisKafkaCluster() - Method in class io.confluent.kafka.multitenant.authorizer.TenantAclProvider
 
usesMetadataFromThisKafkaCluster() - Method in class io.confluent.kafka.security.authorizer.acl.AclProvider
 
Utils - Class in io.confluent.kafka.multitenant.utils
 
Utils() - Constructor for class io.confluent.kafka.multitenant.utils.Utils
 
uuid() - Method in class io.confluent.kafka.security.audit.event.ConfluentAuthenticationEvent
 

V

validate(AlterConfigPolicy.RequestMetadata) - Method in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy
We don't allow any config updates using the external listener where all principals are MultiTenantPrincipals.
validate(Optional<String>, String) - Method in class io.confluent.kafka.server.plugins.policy.CreateClusterLinkPolicy
 
validate(CreateTopicPolicy.RequestMetadata) - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy
 
validateBrokerConfigs(AlterConfigPolicy.RequestMetadata) - Method in class io.confluent.kafka.server.plugins.policy.AlterConfigPolicy.ClusterPolicyConfig
 
validateClusterLinkConfigs(Map<String, String>) - Method in class io.confluent.kafka.server.plugins.policy.ClusterLinkPolicyConfig
 
validateConfigsAreUpdatable(Map<String, String>, Predicate<String>) - Static method in class io.confluent.kafka.server.plugins.policy.PolicyUtils
 
validatePublicKey(String) - Static method in class io.confluent.kafka.server.plugins.auth.token.TokenBearerServerLoginCallbackHandler
 
validateReconfiguration(Map<String, ?>) - Method in class io.confluent.kafka.multitenant.quota.TenantQuotaCallback
 
validateReconfiguration(Map<String, ?>) - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
validateReconfiguration(Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.policy.CreateClusterLinkPolicy
 
validateReconfiguration(Map<String, ?>) - Method in class io.confluent.kafka.server.plugins.policy.CreateTopicPolicy
 
validateTopicConfigs(Map<String, String>) - Method in class io.confluent.kafka.server.plugins.policy.TopicPolicyConfig
 
value() - Method in enum io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsStore.State
 
valueOf(String) - Static method in enum io.confluent.kafka.multitenant.PhysicalClusterMetadata.State
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata.State
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsStore.State
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.confluent.kafka.server.plugins.auth.SniValidationMode
Returns the enum constant of this type with the specified name.
values() - Static method in enum io.confluent.kafka.multitenant.PhysicalClusterMetadata.State
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.confluent.kafka.multitenant.TopicBasedPhysicalClusterMetadata.State
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.confluent.kafka.server.plugins.auth.MultiTenantSaslSecretsStore.State
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.confluent.kafka.server.plugins.auth.SniValidationMode
Returns an array containing the constants of this enum type, in the order they are declared.
VISIBLE_BROKER_CONFIGS - Static variable in class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions
 
VISIBLE_CLUSTER_LINK_CONFIGS - Static variable in class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions
 
visibleTopicConfig(String, boolean) - Static method in class io.confluent.kafka.multitenant.MultiTenantConfigRestrictions
 

W

wrap(byte[], int, int) - Method in class io.confluent.kafka.server.plugins.auth.PlainSaslServer
 
write(EntityType, String) - Method in class io.confluent.kafka.link.LinkContext
 
write(EntityType, Message) - Method in class io.confluent.kafka.link.LinkContext
 
write(EntityType, String) - Method in class io.confluent.kafka.multitenant.schema.TenantContext
 
write(EntityType, Message) - Method in class io.confluent.kafka.multitenant.schema.TenantContext
 
writeKeyPair(OutputStream, KeyPair) - Static method in class io.confluent.common.security.utils.PemUtils
 
writePublicKey(OutputStream, PublicKey) - Static method in class io.confluent.common.security.utils.PemUtils
 
writeTo(CodedOutputStream) - Method in class io.confluent.protobuf.cloud.events.v1.ChangeEventMetadata
 
writeTo(CodedOutputStream) - Method in class io.confluent.protobuf.cloud.events.v1.EventsMetadata
 
writeTo(CodedOutputStream) - Method in class io.confluent.protobuf.cloud.events.v1.LogicalCluster
 

Z

zkAclProvider() - Method in class io.confluent.kafka.security.authorizer.ConfluentServerAuthorizer
 
A B C D E F G H I K L M N O P Q R S T U V W Z 
Skip navigation links