Index (ce-licensing 8.2.0-ce API)

A B C D E F G H I L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

accept(LicenseChanged) - Method in class io.confluent.license.validator.ConfluentLicenseValidator
ACTIVE - Enum constant in enum class io.confluent.license.LicenseManager.LicenseStatus
addCluster(String, LicenseManager.ClusterClient) - Method in class io.confluent.license.LicenseManager: Add another Kafka cluster to be considered when validating a license.
addCluster(String, Map<String, Object>) - Method in class io.confluent.license.LicenseManager: Add another Kafka cluster to be considered when validating a license.
addListener(Consumer<LicenseChanged>) - Method in interface io.confluent.license.AddOnLicenseManager
addListener(Consumer<LicenseChanged>) - Method in class io.confluent.license.AddOnLicenseManagerImpl
addListener(Consumer<LicenseChanged>) - Method in class io.confluent.license.LicenseManager: Add a listener for subsequent license changes.
addListener(Consumer<LicenseChanged>) - Method in class io.confluent.license.TrialOnlyLicenseManager
AddOnLicenseManager - Interface in io.confluent.license
AddOnLicenseManagerImpl - Class in io.confluent.license
AddOnLicenseManagerImpl(ConfluentLicenseStore, LicenseManagerPurpose, String, Time) - Constructor for class io.confluent.license.AddOnLicenseManagerImpl
AddOnLicenseManagerImpl(String, Map<String, Object>, Map<String, Object>, Map<String, Object>, LicenseManagerPurpose, String) - Constructor for class io.confluent.license.AddOnLicenseManagerImpl: Create a new license manager that uses the specified topic for licenses, configurations for an admin client, producer, and consumer to create, write to, and read from that topic in a primary Kafka cluster.
ADMIN_PREFIX - Static variable in class io.confluent.license.validator.LicenseConfig
audience() - Method in class io.confluent.license.License: Get the audience for the license.
audienceString() - Method in class io.confluent.license.License: Get a string with comma-separated audience literals for the license.

B

baseClaims(String, long, boolean) - Static method in class io.confluent.license.License
BrokerDetectionException - Exception Class in io.confluent.license.kafka: Exception thrown when there's an error during broker detection.
BrokerDetectionException(String) - Constructor for exception class io.confluent.license.kafka.BrokerDetectionException
BrokerDetectionException(String, Throwable) - Constructor for exception class io.confluent.license.kafka.BrokerDetectionException
BrokerDetector - Interface in io.confluent.license.kafka: Interface for detecting Kafka broker type.
BrokerType - Enum Class in io.confluent.license.kafka: Enum representing different types of Kafka brokers that can be detected.
build() - Method in class io.confluent.license.util.LicenseTopicAdmin.NewTopicBuilder: Build the NewTopic representation.

C

Callback<V> - Interface in io.confluent.license.util: Generic interface for callbacks
cancel(boolean) - Method in class io.confluent.license.util.ConvertingFutureCallback
CC_SERVICE - Enum constant in enum class io.confluent.license.util.LicenseAddonTypes
close() - Method in class io.confluent.license.util.LicenseTopicAdmin
close() - Method in class io.confluent.license.validator.ConfluentLicenseValidator
close(Duration) - Method in class io.confluent.license.util.LicenseTopicAdmin
compacted() - Method in class io.confluent.license.util.LicenseTopicAdmin.NewTopicBuilder: Specify that the topic should be compacted.
complete(long) - Method in class io.confluent.license.util.Stage
completed() - Method in class io.confluent.license.util.Stage
config(Map<String, Object>) - Method in class io.confluent.license.util.LicenseTopicAdmin.NewTopicBuilder: Specify the configuration properties for the topic, overwriting any previously-set properties.
configure(Map<String, ?>) - Method in class io.confluent.license.validator.ConfluentLicenseValidator
configuredLicense() - Method in class io.confluent.license.LicenseManager
CONFLUENT_CLOUD - Enum constant in enum class io.confluent.license.kafka.BrokerType
CONFLUENT_COMMAND_TOPIC - Static variable in class io.confluent.license.validator.LicenseConfig
CONFLUENT_PLATFORM - Enum constant in enum class io.confluent.license.kafka.BrokerType
ConfluentLicenseStore - Interface in io.confluent.license.store: Interface for Confluent license storage implementations.
ConfluentLicenseValidator - Class in io.confluent.license.validator: License validator used by Kafka brokers for proprietary features.
ConfluentLicenseValidator() - Constructor for class io.confluent.license.validator.ConfluentLicenseValidator
ConfluentLicenseValidator.LicenseStatus - Enum Class in io.confluent.license.validator
CONSUMER_PREFIX - Static variable in class io.confluent.license.validator.LicenseConfig
consumerConfigs() - Method in class io.confluent.license.validator.LicenseConfig
convert(T) - Method in class io.confluent.license.util.FutureCallback
convert(U) - Method in class io.confluent.license.util.ConvertingFutureCallback
ConvertingFutureCallback<U,T> - Class in io.confluent.license.util: An abstract implementation of Callback that also implements the Future interface.
ConvertingFutureCallback() - Constructor for class io.confluent.license.util.ConvertingFutureCallback
ConvertingFutureCallback(Callback<T>) - Constructor for class io.confluent.license.util.ConvertingFutureCallback
CP - Enum constant in enum class io.confluent.license.License.DeploymentScope
CP_FOR_CC - Enum constant in enum class io.confluent.license.License.DeploymentScope
create() - Static method in interface io.confluent.license.kafka.BrokerDetector: Creates a new instance of the BrokerDetector.
createAddOnLicenseStore(String, Map<String, Object>, Map<String, Object>, Map<String, Object>, LicenseManagerPurpose) - Static method in class io.confluent.license.LicenseStoreFactory
createdOrExistingTopicsCount() - Method in class io.confluent.license.util.LicenseTopicAdmin.TopicCreationResponse
createdTopics() - Method in class io.confluent.license.util.LicenseTopicAdmin.TopicCreationResponse
createdTopicsCount() - Method in class io.confluent.license.util.LicenseTopicAdmin.TopicCreationResponse
createOrFindTopic(NewTopic) - Method in class io.confluent.license.util.LicenseTopicAdmin: Attempt to find or create the topic described by the given definition, returning true if the topic was created or had already existed, or false if the topic did not exist and could not be created.
createOrFindTopics(NewTopic...) - Method in class io.confluent.license.util.LicenseTopicAdmin: Attempt to create the topics described by the given definitions, returning all of the names of those topics that were created by this request.
createTopic(NewTopic) - Method in class io.confluent.license.util.LicenseTopicAdmin: Attempt to create the topic described by the given definition, returning true if the topic was created or false if the topic already existed.
createTopics(NewTopic...) - Method in class io.confluent.license.util.LicenseTopicAdmin: Attempt to create the topics described by the given definitions, returning all of the names of those topics that were created by this request.
createTopicsWithRetry(NewTopic, long, long, Time) - Method in class io.confluent.license.util.LicenseTopicAdmin: Implements a retry logic around creating topic(s) in case it'd fail due to specific type of exceptions, see LicenseTopicAdmin.retryableTopicCreationException(ConnectException)
createTopicTimeoutMs() - Method in class io.confluent.license.util.LicenseKafkaBasedLog
createTrialOnlyLicenseStore(String, Map<String, Object>, Map<String, Object>, Map<String, Object>, String) - Static method in class io.confluent.license.LicenseStoreFactory
CSFLE - Enum constant in enum class io.confluent.license.License.Type
CSFLE - Enum constant in enum class io.confluent.license.LicenseManagerPurpose
CSFLE - Enum constant in enum class io.confluent.license.util.LicenseAddonTypes
CSFLELicense - Class in io.confluent.license
CSFLELicense(JwtClaims, Time, String) - Constructor for class io.confluent.license.CSFLELicense: Create a license with the supplied JWT Claims.

D

DEFAULT - Enum constant in enum class io.confluent.license.LicenseAutoGenerationPolicy: Default license generation behavior based on cluster topology.
defaultPartitions() - Method in class io.confluent.license.util.LicenseTopicAdmin.NewTopicBuilder: Specify the topic's number of partition should be the broker configuration for num.partitions.
defaultReplicationFactor() - Method in class io.confluent.license.util.LicenseTopicAdmin.NewTopicBuilder: Specify the replication factor for the topic should be the broker configurations for default.replication.factor.
defineTopic(String) - Static method in class io.confluent.license.util.LicenseTopicAdmin: Obtain a builder to define a NewTopic.
deploymentScope() - Method in class io.confluent.license.License
describeTopicConfig(String) - Method in class io.confluent.license.util.LicenseTopicAdmin: Attempt to fetch the topic configuration for the given topic.
describeTopicConfigs(String...) - Method in class io.confluent.license.util.LicenseTopicAdmin: Attempt to fetch the topic configurations for the given topics.
describeTopics(String...) - Method in class io.confluent.license.util.LicenseTopicAdmin: Attempt to fetch the descriptions of the given topics Apache Kafka added support for describing topics in 0.10.0.0, so this method works as expected with that and later versions.
description() - Method in interface io.confluent.license.LicenseChanged: Get a description of this license, perhaps including a reason why this license is used.
description() - Method in class io.confluent.license.util.Stage
determineBrokerType(Map<String, Object>) - Method in interface io.confluent.license.kafka.BrokerDetector: Detects the type of broker based on the provided configuration.
determineBrokerType(Properties) - Method in interface io.confluent.license.kafka.BrokerDetector: Detects the type of broker based on the provided configuration.

E

EMPTY_CREATION - Static variable in class io.confluent.license.util.LicenseTopicAdmin
enabled() - Method in class io.confluent.license.validator.ConfluentLicenseValidator
endOffsets(Set<TopicPartition>) - Method in class io.confluent.license.util.LicenseTopicAdmin: Fetch the most recent offset for each of the supplied TopicPartition objects.
ENTERPRISE - Enum constant in enum class io.confluent.license.License.Type
equals(Object) - Method in class io.confluent.license.License
existingLicenses() - Method in interface io.confluent.license.LicenseChanged: Returns the list of existing licenses after this change.
existingTopicsCount() - Method in class io.confluent.license.util.LicenseTopicAdmin.TopicCreationResponse
expirationDate() - Method in class io.confluent.license.License: Get the license's expiration date.
expirationDateString() - Method in class io.confluent.license.License: Get the license's expiration date as a formatted string of the form "yyyy-MM-dd".
EXPIRED - Enum constant in enum class io.confluent.license.LicenseChanged.Type: The license has expired.
EXPIRED - Enum constant in enum class io.confluent.license.LicenseManager.LicenseStatus
ExpiredLicenseException - Exception Class in io.confluent.license
ExpiredLicenseException(License, String) - Constructor for exception class io.confluent.license.ExpiredLicenseException
ExpiredLicenseException(License, String, Throwable) - Constructor for exception class io.confluent.license.ExpiredLicenseException
ExpiredLicensesException - Exception Class in io.confluent.license
ExpiredLicensesException(List<License>, String) - Constructor for exception class io.confluent.license.ExpiredLicensesException
expiresBefore(License) - Method in class io.confluent.license.CSFLELicense: Determine if this license expires before the specified license
expiresBefore(License) - Method in class io.confluent.license.License: Determine if this license expires before the specified license.

F

flush() - Method in class io.confluent.license.util.LicenseKafkaBasedLog: Flush the underlying producer to ensure that all pending writes have been sent.
FREE_TIER - Enum constant in enum class io.confluent.license.License.Type
FREE_TIER - Enum constant in enum class io.confluent.license.validator.ConfluentLicenseValidator.LicenseStatus
FREE_TIER_EXPIRED - Enum constant in enum class io.confluent.license.validator.ConfluentLicenseValidator.LicenseStatus
FutureCallback<T> - Class in io.confluent.license.util: An implementation of ConvertingFutureCallback that doesn't do any conversion - i.e.
FutureCallback() - Constructor for class io.confluent.license.util.FutureCallback
FutureCallback(Callback<T>) - Constructor for class io.confluent.license.util.FutureCallback

G

generateTrialLicense(JwtClaims) - Static method in class io.confluent.license.License
get() - Method in class io.confluent.license.util.ConvertingFutureCallback
get() - Method in class io.confluent.license.validator.ConfluentLicenseValidator: Provides LicenseTrackingInfoHolder, which is used to retrieve tracking identifiers from License to Segment without exposing internal LicenseManager or License.
get(long, TimeUnit) - Method in class io.confluent.license.util.ConvertingFutureCallback
getAudience(JwtClaims) - Static method in class io.confluent.license.License
getDescription() - Method in enum class io.confluent.license.LicenseManager.LicenseStatus
getExpiration(JwtClaims) - Static method in class io.confluent.license.License
getExpiredList() - Method in exception class io.confluent.license.ExpiredLicensesException
getLatestLicenses() - Method in class io.confluent.license.LicenseStore: Reads the license store LicenseStore and returns the latest licenses per License.DeploymentScope.
getLatestLicenses() - Method in interface io.confluent.license.store.ConfluentLicenseStore: Get all licenses with their corresponding type Simple stores should return an empty map.
getLicense() - Method in exception class io.confluent.license.ExpiredLicenseException
getLicenseSubType() - Method in class io.confluent.license.License: Get the license subtype from the JWT claims.
getValue() - Method in enum class io.confluent.license.util.LicenseAddonTypes

H

hashCode() - Method in class io.confluent.license.License

I

InMemoryLicenseStore - Class in io.confluent.license.store
InMemoryLicenseStore() - Constructor for class io.confluent.license.store.InMemoryLicenseStore
INVALID - Enum constant in enum class io.confluent.license.LicenseChanged.Type: The license is invalid.
INVALID - Enum constant in enum class io.confluent.license.LicenseManager.LicenseStatus
INVALID_LICENSE - Enum constant in enum class io.confluent.license.validator.ConfluentLicenseValidator.LicenseStatus
InvalidLicenseException - Exception Class in io.confluent.license
InvalidLicenseException(String) - Constructor for exception class io.confluent.license.InvalidLicenseException
InvalidLicenseException(String, Throwable) - Constructor for exception class io.confluent.license.InvalidLicenseException
io.confluent.license - package io.confluent.license
io.confluent.license.kafka - package io.confluent.license.kafka
io.confluent.license.store - package io.confluent.license.store
io.confluent.license.util - package io.confluent.license.util
io.confluent.license.validator - package io.confluent.license.validator
isBlank(String) - Static method in class io.confluent.license.util.StringUtils
isCancelled() - Method in class io.confluent.license.util.ConvertingFutureCallback
isCreated(String) - Method in class io.confluent.license.util.LicenseTopicAdmin.TopicCreationResponse
isCreatedOrExisting(String) - Method in class io.confluent.license.util.LicenseTopicAdmin.TopicCreationResponse
isCSFLE() - Method in class io.confluent.license.CSFLELicense
isDone() - Method in class io.confluent.license.util.ConvertingFutureCallback
isEmpty() - Method in class io.confluent.license.util.LicenseTopicAdmin.TopicCreationResponse
isEnterprise() - Method in class io.confluent.license.License: Determine whether the license represents a Enterprise license.
isEquivalentTo(License) - Method in class io.confluent.license.License: Determine if this license is equivalent to the specified license, using the audience, expiration time, issuer, subject, and monitoring claim.
isExisting(String) - Method in class io.confluent.license.util.LicenseTopicAdmin.TopicCreationResponse
isExpired() - Method in class io.confluent.license.CSFLELicense
isExpired() - Method in class io.confluent.license.License: Determine whether this license has expired.
isFreeTier() - Method in class io.confluent.license.License: Determine whether the license represents a free tier license that allows for single-node clusters only.
isInvalidLicense() - Method in class io.confluent.license.License
isLicenseValid() - Method in class io.confluent.license.validator.ConfluentLicenseValidator
isNotBlank(String) - Static method in class io.confluent.license.util.StringUtils
isRenewalOf(License) - Method in class io.confluent.license.CSFLELicense
isRenewalOf(License) - Method in class io.confluent.license.License: Determine if this license is a strict renewal of the specified license.
isSubTypeCpc() - Method in class io.confluent.license.validator.ConfluentLicenseValidator
isTrial() - Method in class io.confluent.license.License: Determine whether the license represents a trial, such that the audience is simply "trial".
isUpdatedWithSameExpiry(License) - Method in class io.confluent.license.License: Determine if this license is an updated version of the specified license with the same expiration date.
isValid() - Method in class io.confluent.license.CSFLELicense
isValid() - Method in class io.confluent.license.License: Determine whether this license is currently valid.

L

license - Variable in class io.confluent.license.validator.LicenseConfig
license() - Method in interface io.confluent.license.LicenseChanged: Get the license.
License - Class in io.confluent.license: this class provides utility functions and a cli for creating/verifying licenses
License(JwtClaims, Time, String) - Constructor for class io.confluent.license.License: Create a license with the supplied JWT Claims.
License(JwtClaims, Time, String, String) - Constructor for class io.confluent.license.License: Create a license with the supplied JWT Claims and cluster id.
LICENSE_ACTIVE - Enum constant in enum class io.confluent.license.validator.ConfluentLicenseValidator.LicenseStatus
LICENSE_EXPIRED - Enum constant in enum class io.confluent.license.validator.ConfluentLicenseValidator.LicenseStatus
LICENSE_PROP - Static variable in class io.confluent.license.validator.LicenseConfig
License.DeploymentScope - Enum Class in io.confluent.license: Defines the deployment scope where a license can be used.
License.LicenseSubType - Enum Class in io.confluent.license: Defines the subtype of a license, providing additional categorization beyond the basic license type.
License.Type - Enum Class in io.confluent.license: Supported License Types:
LicenseAddonTypes - Enum Class in io.confluent.license.util
LicenseAutoGenerationPolicy - Enum Class in io.confluent.license: Defines the automatic license generation policy when no valid license exists.
LicenseChanged - Interface in io.confluent.license: An event signaling that the license has changed.
LicenseChanged.Type - Enum Class in io.confluent.license: The type of license change.
LicenseConfig - Class in io.confluent.license.validator
LicenseConfig(String, Map<?, ?>) - Constructor for class io.confluent.license.validator.LicenseConfig
licenseId() - Method in class io.confluent.license.License: The license id.
LicenseKafkaBasedLog<K,V> - Class in io.confluent.license.util: KafkaBasedLog provides a generic implementation of a shared, compacted log of records stored in Kafka that all clients need to consume and, at times, agree on their offset / that they have read to the end of the log.
LicenseKafkaBasedLog(String, Map<String, Object>, Map<String, Object>, Callback<ConsumerRecord<K, V>>, Time, Runnable) - Constructor for class io.confluent.license.util.LicenseKafkaBasedLog: Deprecated.
Replaced by LicenseKafkaBasedLog(String, Map, Map, Supplier, Callback, Time, java.util.function.Consumer)
LicenseKafkaBasedLog(String, Map<String, Object>, Map<String, Object>, Callback<ConsumerRecord<K, V>>, Time, Runnable, long) - Constructor for class io.confluent.license.util.LicenseKafkaBasedLog: Deprecated.
Replaced by LicenseKafkaBasedLog(String, Map, Map, Supplier, Callback, Time, java.util.function.Consumer, long)
LicenseKafkaBasedLog(String, Map<String, Object>, Map<String, Object>, Supplier<LicenseTopicAdmin>, Callback<ConsumerRecord<K, V>>, Time, Consumer<LicenseTopicAdmin>) - Constructor for class io.confluent.license.util.LicenseKafkaBasedLog: Create a new KafkaBasedLog object.
LicenseKafkaBasedLog(String, Map<String, Object>, Map<String, Object>, Supplier<LicenseTopicAdmin>, Callback<ConsumerRecord<K, V>>, Time, Consumer<LicenseTopicAdmin>, long) - Constructor for class io.confluent.license.util.LicenseKafkaBasedLog: Create a new KafkaBasedLog object.
LicenseKeySerde() - Constructor for class io.confluent.license.LicenseStore.LicenseKeySerde
LicenseManager - Class in io.confluent.license: A license manager that can validate and store Confluent licenses in a topic in one Kafka cluster.
LicenseManager(ConfluentLicenseStore, String) - Constructor for class io.confluent.license.LicenseManager
LicenseManager(ConfluentLicenseStore, String, LicenseAutoGenerationPolicy) - Constructor for class io.confluent.license.LicenseManager
LicenseManager(ConfluentLicenseStore, String, LicenseManagerPurpose) - Constructor for class io.confluent.license.LicenseManager
LicenseManager(ConfluentLicenseStore, String, LicenseManagerPurpose, Time) - Constructor for class io.confluent.license.LicenseManager
LicenseManager(ConfluentLicenseStore, String, LicenseManagerPurpose, Time, LicenseAutoGenerationPolicy) - Constructor for class io.confluent.license.LicenseManager
LicenseManager(String, Map<String, Object>, Map<String, Object>, Map<String, Object>) - Constructor for class io.confluent.license.LicenseManager: Create a new license manager that uses the specified topic for licenses, configurations for an admin client, producer, and consumer to create, write to, and read from that topic in a primary Kafka cluster.
LicenseManager(String, Map<String, Object>, Map<String, Object>, Map<String, Object>, LicenseManagerPurpose) - Constructor for class io.confluent.license.LicenseManager
LicenseManager(String, Map<String, Object>, Map<String, Object>, Map<String, Object>, Duration, Duration, Duration) - Constructor for class io.confluent.license.LicenseManager
LicenseManager(Map<String, Object>, LicenseStore, String, boolean) - Constructor for class io.confluent.license.LicenseManager
LicenseManager(Map<String, Object>, LicenseStore, String, boolean, boolean) - Constructor for class io.confluent.license.LicenseManager
LicenseManager.LicenseStatus - Enum Class in io.confluent.license: License status enumeration for license validation operations
LicenseManagerPurpose - Enum Class in io.confluent.license
LicenseMessageSerde() - Constructor for class io.confluent.license.LicenseStore.LicenseMessageSerde
licenseScan() - Method in class io.confluent.license.LicenseStore: Returns a single license only when LicenseStore is configured with exactly one Command.CommandKey.
licenseScan() - Method in interface io.confluent.license.store.ConfluentLicenseStore
licenseScan() - Method in class io.confluent.license.store.InMemoryLicenseStore
LicenseSelectionStrategy - Class in io.confluent.license: A strategy class that accepts a lambda function to select a license from a list of licenses.
LicenseSelectionStrategy() - Constructor for class io.confluent.license.LicenseSelectionStrategy: Creates a new LicenseSelectionStrategy with the default longest expiry strategy.
LicenseSelectionStrategy(Function<List<License>, License>) - Constructor for class io.confluent.license.LicenseSelectionStrategy: Creates a new LicenseSelectionStrategy with the provided selection function.
LicenseStore - Class in io.confluent.license: IMPORTANT: This class should not use Kafka APIs newer than AK 0.11.0/CP 3.3.0.
LicenseStore(Command.CommandKey, String, ConcurrentHashMap<Command.CommandKey, String>, LicenseKafkaBasedLog<Command.CommandKey, Command.CommandMessage>, Time) - Constructor for class io.confluent.license.LicenseStore
LicenseStore(String, Map<String, Object>, Map<String, Object>, Map<String, Object>) - Constructor for class io.confluent.license.LicenseStore
LicenseStore(String, Map<String, Object>, Map<String, Object>, Map<String, Object>, Duration, Duration, Duration, Time) - Constructor for class io.confluent.license.LicenseStore
LicenseStore(String, Map<String, Object>, Map<String, Object>, Map<String, Object>, Duration, Duration, Duration, Time, List<Command.CommandKey>) - Constructor for class io.confluent.license.LicenseStore
LicenseStore(String, Map<String, Object>, Map<String, Object>, Map<String, Object>, List<Command.CommandKey>) - Constructor for class io.confluent.license.LicenseStore
LicenseStore(List<Command.CommandKey>, String, ConcurrentHashMap<Command.CommandKey, String>, LicenseKafkaBasedLog<Command.CommandKey, Command.CommandMessage>, Time) - Constructor for class io.confluent.license.LicenseStore
LicenseStore.ConsumeCallback - Class in io.confluent.license
LicenseStore.LicenseKeySerde - Class in io.confluent.license
LicenseStore.LicenseMessageSerde - Class in io.confluent.license
LicenseStoreFactory - Class in io.confluent.license
LicenseStoreFactory() - Constructor for class io.confluent.license.LicenseStoreFactory
LicenseTopicAdmin - Class in io.confluent.license.util: Utility to simplify creating and managing topics via the Admin.
LicenseTopicAdmin(Map<String, Object>) - Constructor for class io.confluent.license.util.LicenseTopicAdmin: Create a new topic admin component with the given configuration.
LicenseTopicAdmin(Map<String, Object>, Admin) - Constructor for class io.confluent.license.util.LicenseTopicAdmin
LicenseTopicAdmin.NewTopicBuilder - Class in io.confluent.license.util: A builder of NewTopic instances.
LicenseTopicAdmin.TopicCreationResponse - Class in io.confluent.license.util
loadPrivateKey(InputStream) - Static method in class io.confluent.license.License
loadPublicKey() - Static method in class io.confluent.license.License
loadPublicKey() - Static method in class io.confluent.license.LicenseManager
loadPublicKey(InputStream) - Static method in class io.confluent.license.License

M

main(String[]) - Static method in class io.confluent.license.validator.LicenseConfig
maybeWrap(Throwable, String) - Static method in class io.confluent.license.util.LicenseTopicAdmin
METRIC_GROUP - Static variable in class io.confluent.license.validator.ConfluentLicenseValidator
METRIC_NAME - Static variable in class io.confluent.license.validator.ConfluentLicenseValidator
MIN_INSYNC_REPLICAS_CONFIG - Static variable in class io.confluent.license.LicenseStore
minInSyncReplicas(short) - Method in class io.confluent.license.util.LicenseTopicAdmin.NewTopicBuilder: Specify the minimum number of in-sync replicas required for this topic.

N

NO_PARTITIONS - Static variable in class io.confluent.license.util.LicenseTopicAdmin
NO_REPLICATION_FACTOR - Static variable in class io.confluent.license.util.LicenseTopicAdmin
NONE - Enum constant in enum class io.confluent.license.License.LicenseSubType: Default subtype when no licenseSubType claim is present in the JWT.

O

onCompletion(Throwable, ConsumerRecord<Command.CommandKey, Command.CommandMessage>) - Method in class io.confluent.license.LicenseStore.ConsumeCallback
onCompletion(Throwable, U) - Method in class io.confluent.license.util.ConvertingFutureCallback
onCompletion(Throwable, V) - Method in interface io.confluent.license.util.Callback: Invoked upon completion of the operation.

P

partitionCount() - Method in class io.confluent.license.util.LicenseKafkaBasedLog
partitions(int) - Method in class io.confluent.license.util.LicenseTopicAdmin.NewTopicBuilder: Specify the desired number of partitions for the topic.
platformId() - Method in class io.confluent.license.License: The platform id for the licensing server.
PREFIX - Static variable in class io.confluent.license.validator.LicenseConfig
PRIMARY - Enum constant in enum class io.confluent.license.LicenseManagerPurpose
PRIVATE_CLOUD - Enum constant in enum class io.confluent.license.License.LicenseSubType: Private Cloud license subtype, indicated by "PrivateCloud" value in the licenseSubType JWT claim.
PRODUCER_PREFIX - Static variable in class io.confluent.license.validator.LicenseConfig
producerConfigs() - Method in class io.confluent.license.validator.LicenseConfig

R

READ_TO_END_TIMEOUT_MS - Static variable in class io.confluent.license.LicenseStore
readToEnd() - Method in class io.confluent.license.util.LicenseKafkaBasedLog: Same as LicenseKafkaBasedLog.readToEnd(Callback) but provides a Future instead of using a callback.
readToEnd(Callback<Void>) - Method in class io.confluent.license.util.LicenseKafkaBasedLog: Flushes any outstanding writes and then reads to the current end of the log and invokes the specified callback.
registerLicense(License.DeploymentScope, String) - Method in class io.confluent.license.LicenseStore: Registers a license JWT for the given License.DeploymentScope.
registerLicense(License.DeploymentScope, String) - Method in interface io.confluent.license.store.ConfluentLicenseStore
registerLicense(String) - Method in class io.confluent.license.LicenseStore: Supports single-license LicenseStore only.
registerLicense(String) - Method in interface io.confluent.license.store.ConfluentLicenseStore
registerLicense(String) - Method in class io.confluent.license.store.InMemoryLicenseStore
registerLicense(String, Callback) - Method in class io.confluent.license.LicenseStore: Supports single-license LicenseStore only.
registerOrValidateAddOnLicense(String) - Method in interface io.confluent.license.AddOnLicenseManager
registerOrValidateAddOnLicense(String) - Method in class io.confluent.license.AddOnLicenseManagerImpl
registerOrValidateAddOnLicense(String) - Method in class io.confluent.license.LicenseManager: Validate the supplied license, or if blank register a new trial license.
registerOrValidateAddOnLicense(String) - Method in class io.confluent.license.TrialOnlyLicenseManager: Register or validate only a trial license.
registerOrValidateLicense(String) - Method in class io.confluent.license.LicenseManager: Validates a supplied CP or 'CP for CC' license and persists it in LicenseStore.
registerOrValidateMultiLicense(String, boolean) - Method in class io.confluent.license.LicenseManager: Validates a supplied CP or 'CP for CC' license, persists it in LicenseStore.
removeCluster(String) - Method in class io.confluent.license.LicenseManager: Remove the Kafka cluster client with the specific name from being considered when validating a license.
removeListener(Consumer<LicenseChanged>) - Method in class io.confluent.license.LicenseManager: Remove a previously registered license change listener.
RENEWAL - Enum constant in enum class io.confluent.license.LicenseChanged.Type: The license has been renewed, meaning the new license is identical to the previous license except that the expiration date has been extended.
REPLICATION_FACTOR_CONFIG - Static variable in class io.confluent.license.LicenseStore
REPLICATION_FACTOR_PROP - Static variable in class io.confluent.license.validator.LicenseConfig
replicationFactor(short) - Method in class io.confluent.license.util.LicenseTopicAdmin.NewTopicBuilder: Specify the desired replication factor for the topic.
RETRY_BACKOFF_MAX_MS_DEFAULT - Static variable in class io.confluent.license.validator.LicenseConfig
RETRY_BACKOFF_MAX_MS_DOC - Static variable in class io.confluent.license.validator.LicenseConfig
RETRY_BACKOFF_MAX_MS_PROP - Static variable in class io.confluent.license.validator.LicenseConfig
RETRY_BACKOFF_MIN_MS_DEFAULT - Static variable in class io.confluent.license.validator.LicenseConfig
RETRY_BACKOFF_MIN_MS_DOC - Static variable in class io.confluent.license.validator.LicenseConfig
RETRY_BACKOFF_MIN_MS_PROP - Static variable in class io.confluent.license.validator.LicenseConfig
retryEndOffsets(Set<TopicPartition>, Duration, long) - Method in class io.confluent.license.util.LicenseTopicAdmin: Fetch the most recent offset for each of the supplied TopicPartition objects, and performs retry when RetriableException is thrown.
retryUntilTimeout(Callable<T>, Supplier<String>, Duration, long) - Static method in class io.confluent.license.util.RetryUtil: The method executes the callable at least once, optionally retrying the callable if RetriableException is being thrown.
RetryUtil - Class in io.confluent.license.util
RetryUtil() - Constructor for class io.confluent.license.util.RetryUtil

S

selectLicense(List<License>) - Method in class io.confluent.license.LicenseSelectionStrategy: Selects a license from the provided list using the configured selection function.
send(K, V, Callback) - Method in class io.confluent.license.util.LicenseKafkaBasedLog: Send a record asynchronously to the configured LicenseKafkaBasedLog.topic.
sendWithReceipt(K, V, Callback) - Method in class io.confluent.license.util.LicenseKafkaBasedLog: Send a record asynchronously to the configured LicenseKafkaBasedLog.topic.
serializedForm() - Method in class io.confluent.license.License: Get the serialized form of this license.
setSchedulingStrategy(Function<List<License>, License>) - Method in class io.confluent.license.LicenseManager
sign(PrivateKey, String, long, boolean) - Static method in class io.confluent.license.License
stage() - Method in exception class io.confluent.license.util.StagedTimeoutException
Stage - Class in io.confluent.license.util
Stage(String, long) - Constructor for class io.confluent.license.util.Stage
StagedTimeoutException - Exception Class in io.confluent.license.util
StagedTimeoutException(Stage) - Constructor for exception class io.confluent.license.util.StagedTimeoutException
start() - Method in interface io.confluent.license.AddOnLicenseManager
start() - Method in class io.confluent.license.AddOnLicenseManagerImpl
start() - Method in class io.confluent.license.LicenseManager: Begin running this license manager's check on a daily schedule, or more frequently if the license is expired or has less than 1 day remaining.
start() - Method in class io.confluent.license.LicenseStore
start() - Method in interface io.confluent.license.store.ConfluentLicenseStore
start() - Method in class io.confluent.license.store.InMemoryLicenseStore
start() - Method in class io.confluent.license.TrialOnlyLicenseManager
start() - Method in class io.confluent.license.util.LicenseKafkaBasedLog
start(boolean) - Method in class io.confluent.license.util.LicenseKafkaBasedLog
start(long, long, TimeUnit) - Method in class io.confluent.license.LicenseManager: Begin running this license manager's check with a configurable initial delay and period.
start(String) - Method in class io.confluent.license.validator.ConfluentLicenseValidator
started() - Method in class io.confluent.license.util.Stage
stop() - Method in interface io.confluent.license.AddOnLicenseManager
stop() - Method in class io.confluent.license.AddOnLicenseManagerImpl
stop() - Method in class io.confluent.license.LicenseManager: Stop this license manager, close any resources, and remove any scheduled license checks.
stop() - Method in class io.confluent.license.LicenseStore
stop() - Method in interface io.confluent.license.store.ConfluentLicenseStore
stop() - Method in class io.confluent.license.store.InMemoryLicenseStore
stop() - Method in class io.confluent.license.TrialOnlyLicenseManager
stop() - Method in class io.confluent.license.util.LicenseKafkaBasedLog
StringUtils - Class in io.confluent.license.util: Simple string utilities, not present in java library, that are not worth importing a dependency.
StringUtils() - Constructor for class io.confluent.license.util.StringUtils
subject() - Method in class io.confluent.license.License: Get the subject of the license.
summarize() - Method in class io.confluent.license.util.Stage
Supported Enterprise License Subcategories: - Search tag in enum class io.confluent.license.License.Type: Section
Supported License Types: - Search tag in enum class io.confluent.license.License.Type: Section

T

timeRemaining(TimeUnit) - Method in class io.confluent.license.CSFLELicense
timeRemaining(TimeUnit) - Method in class io.confluent.license.License: Get the amount of time in the specified units that remains before the license expires.
timeUntilLicenseExpirationMs() - Method in class io.confluent.license.LicenseManager
timeUntilLicenseExpirationMs(long) - Method in class io.confluent.license.LicenseManager
topic - Variable in class io.confluent.license.validator.LicenseConfig
topic() - Method in class io.confluent.license.LicenseStore
TOPIC_CREATE_TIMEOUT_DEFAULT - Static variable in class io.confluent.license.validator.LicenseConfig
TOPIC_CREATE_TIMEOUT_DOC - Static variable in class io.confluent.license.validator.LicenseConfig
TOPIC_CREATE_TIMEOUT_PROP - Static variable in class io.confluent.license.validator.LicenseConfig
TOPIC_DEFAULT - Static variable in class io.confluent.license.validator.LicenseConfig
TOPIC_PROP - Static variable in class io.confluent.license.validator.LicenseConfig
topicAndAdminClientConfigs() - Method in class io.confluent.license.validator.LicenseConfig
topicCleanupPolicy(String) - Method in class io.confluent.license.util.LicenseTopicAdmin: Get the cleanup policy for a topic.
TopicCreationResponse(Set<String>, Set<String>) - Constructor for class io.confluent.license.util.LicenseTopicAdmin.TopicCreationResponse
toString() - Method in class io.confluent.license.CSFLELicense
toString() - Method in class io.confluent.license.License
toString() - Method in class io.confluent.license.util.LicenseTopicAdmin.TopicCreationResponse
toString() - Method in class io.confluent.license.util.Stage
toString() - Method in class io.confluent.license.validator.LicenseConfig
TRIAL - Enum constant in enum class io.confluent.license.License.Type
TRIAL - Enum constant in enum class io.confluent.license.validator.ConfluentLicenseValidator.LicenseStatus
TRIAL_EXPIRED - Enum constant in enum class io.confluent.license.validator.ConfluentLicenseValidator.LicenseStatus
TRIAL_ONLY - Enum constant in enum class io.confluent.license.LicenseAutoGenerationPolicy: Always generate trial licenses regardless of cluster topology.
TrialOnlyLicenseManager - Class in io.confluent.license: License manager for managing only trial licenses in Confluent Platform.
TrialOnlyLicenseManager(ConfluentLicenseStore, Time) - Constructor for class io.confluent.license.TrialOnlyLicenseManager: Create a new trial only license manager for testing purposes using a pre-configured license store and time source.
TrialOnlyLicenseManager(String, Map<String, Object>, Map<String, Object>, Map<String, Object>, String) - Constructor for class io.confluent.license.TrialOnlyLicenseManager: Create a new trial only license manager that uses the specified topic for trial licenses, with configurations for an admin client, producer, and consumer to create, write to, and read from that topic in a Kafka cluster.
type() - Method in class io.confluent.license.CSFLELicense: Get the type of license.
type() - Method in class io.confluent.license.License: Get the type of license.
type() - Method in interface io.confluent.license.LicenseChanged: The type of change in the license.
Types of Licenses - Search tag in class io.confluent.license.LicenseManager: Section

U

UNKNOWN - Enum constant in enum class io.confluent.license.kafka.BrokerType
UPDATED - Enum constant in enum class io.confluent.license.LicenseChanged.Type: The license has been updated with more changes than just the expiration date.
Usage - Search tag in class io.confluent.license.LicenseManager: Section

V

valueOf(String) - Static method in enum class io.confluent.license.kafka.BrokerType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.license.License.DeploymentScope: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.license.License.LicenseSubType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.license.License.Type: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.license.LicenseAutoGenerationPolicy: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.license.LicenseChanged.Type: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.license.LicenseManager.LicenseStatus: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.license.LicenseManagerPurpose: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.license.util.LicenseAddonTypes: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.confluent.license.validator.ConfluentLicenseValidator.LicenseStatus: Returns the enum constant of this class with the specified name.
values() - Static method in enum class io.confluent.license.kafka.BrokerType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.license.License.DeploymentScope: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.license.License.LicenseSubType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.license.License.Type: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.license.LicenseAutoGenerationPolicy: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.license.LicenseChanged.Type: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.license.LicenseManager.LicenseStatus: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.license.LicenseManagerPurpose: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.license.util.LicenseAddonTypes: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.confluent.license.validator.ConfluentLicenseValidator.LicenseStatus: Returns an array containing the constants of this enum class, in the order they are declared.
verify(PublicKey, String) - Static method in class io.confluent.license.License
verifyMonitoring(JwtClaims) - Static method in class io.confluent.license.License
verifyStored(PublicKey, String) - Static method in class io.confluent.license.License
verifyTopicCleanupPolicyOnlyCompact(String, String, String) - Method in class io.confluent.license.util.LicenseTopicAdmin: Verify the named topic uses only compaction for the cleanup policy.

W

withExistingClients(String, Consumer<K, V>, Producer<K, V>, LicenseTopicAdmin, Callback<ConsumerRecord<K, V>>, Time, Consumer<LicenseTopicAdmin>, Predicate<TopicPartition>) - Static method in class io.confluent.license.util.LicenseKafkaBasedLog: Create a new KafkaBasedLog object using pre-existing Kafka clients.

A B C D E F G H I L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form