Index (ce-licensing 7.4.11-ce API)

A B C D E F G H I L M N O P R S T U V W

A

accept(LicenseChanged) - Method in class io.confluent.license.validator.ConfluentLicenseValidator
addCluster(String, Map<String, Object>) - Method in class io.confluent.license.LicenseManager: Add another Kafka cluster to be considered when validating a license.
addCluster(String, LicenseManager.ClusterClient) - 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(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.
AddOnLicenseManagerImpl(LicenseStore, LicenseManagerPurpose, String, Time) - Constructor for class io.confluent.license.AddOnLicenseManagerImpl
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
brokerCount() - Method in class io.confluent.license.LicenseManager.BasicClusterClient
brokerCount() - Method in interface io.confluent.license.LicenseManager.ClusterClient
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
checkLicense() - Method in class io.confluent.license.validator.ConfluentLicenseValidator
close() - Method in class io.confluent.license.util.LicenseTopicAdmin
close(Duration) - Method in class io.confluent.license.util.LicenseTopicAdmin
close() - Method in class io.confluent.license.validator.ConfluentLicenseValidator
clusterId() - Method in class io.confluent.license.LicenseManager.BasicClusterClient
clusterId() - Method in interface io.confluent.license.LicenseManager.ClusterClient
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_COMMAND_TOPIC - Static variable in class io.confluent.license.validator.LicenseConfig
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(LicenseManager, ScheduledExecutorService, Duration) - Constructor for class io.confluent.license.validator.ConfluentLicenseValidator
ConfluentLicenseValidator.LicenseStatus - Enum 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(U) - Method in class io.confluent.license.util.ConvertingFutureCallback
convert(T) - Method in class io.confluent.license.util.FutureCallback
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
createAddOnLicenseStore(String, Map<String, Object>, Map<String, Object>, Map<String, Object>, LicenseManagerPurpose) - Static method in class io.confluent.license.LicenseStoreFactory
createConfluentLicenseTopic(AdminClient, String, NewTopic) - Method in class io.confluent.license.LicenseStore
createConsumer() - Method in class io.confluent.license.util.LicenseKafkaBasedLog
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
createLicenseManager(LicenseConfig) - Method in class io.confluent.license.validator.ConfluentLicenseValidator
createLicenseStore(LicenseConfig) - Method in class io.confluent.license.validator.ConfluentLicenseValidator
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.
createProducer() - Method in class io.confluent.license.util.LicenseKafkaBasedLog
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
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

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.LicenseManager.LicenseChangedEvent
description() - Method in class io.confluent.license.util.Stage
doStart() - Method in class io.confluent.license.LicenseManager
doStop() - Method in class io.confluent.license.LicenseManager

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.
equals(Object) - Method in class io.confluent.license.License
equals(Object) - Method in class io.confluent.license.LicenseManager.LicenseChangedEvent
existingLicenses() - Method in interface io.confluent.license.LicenseChanged: Returns the list of existing licenses after this change.
existingLicenses() - Method in class io.confluent.license.LicenseManager.LicenseChangedEvent
existingTopicsCount() - Method in class io.confluent.license.util.LicenseTopicAdmin.TopicCreationResponse
expiration(JwtClaims) - Static method in class io.confluent.license.License
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 .
expirationMillis() - Method in class io.confluent.license.CSFLELicense
expirationMillis() - Method in class io.confluent.license.License
ExpiredLicenseException - Exception in io.confluent.license
ExpiredLicenseException(License, String) - Constructor for exception io.confluent.license.ExpiredLicenseException
ExpiredLicenseException(License, String, Throwable) - Constructor for exception io.confluent.license.ExpiredLicenseException
ExpiredLicensesException - Exception in io.confluent.license
ExpiredLicensesException(List<License>, String) - Constructor for exception 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.
FutureCallback<T> - Class in io.confluent.license.util: An implementation of ConvertingFutureCallback that doesn't do any conversion - i.e.
FutureCallback(Callback<T>) - Constructor for class io.confluent.license.util.FutureCallback
FutureCallback() - Constructor for class io.confluent.license.util.FutureCallback

G

generateLicense(long) - Method in class io.confluent.license.LicenseManager
generateTrialLicense(JwtClaims) - Static method in class io.confluent.license.License
get() - Method in class io.confluent.license.util.ConvertingFutureCallback
get(long, TimeUnit) - 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.
getAudience(JwtClaims) - Static method in class io.confluent.license.License
getDescription() - Method in enum io.confluent.license.LicenseManager.LicenseStatus
getExpiration(JwtClaims) - Static method in class io.confluent.license.License
getExpiredList() - Method in exception 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 io.confluent.license.ExpiredLicenseException
getNextCheckIntervalMsAndMaybeLog(long) - Method in class io.confluent.license.validator.ConfluentLicenseValidator
getValue() - Method in enum io.confluent.license.util.LicenseAddonTypes

H

hasAddOnClaims() - Method in class io.confluent.license.License: Determine if this license contains all of the relevant claims
hashCode() - Method in class io.confluent.license.License
hashCode() - Method in class io.confluent.license.LicenseManager.LicenseChangedEvent
hasLicenseType(String) - Method in class io.confluent.license.License
hasMatchingAddOnClaims(License, String...) - Method in class io.confluent.license.License: Determine if this license matches all of the relevant claims in the supplied license, except for any excluded claims.
hasMatchingClaims(License, String...) - Method in class io.confluent.license.License: Determine if this license matches all of the relevant claims in the supplied license, except for any excluded claims.
hasOnlySingleNodeClusters() - Method in class io.confluent.license.LicenseManager

I

InvalidLicenseException - Exception in io.confluent.license
InvalidLicenseException(String) - Constructor for exception io.confluent.license.InvalidLicenseException
InvalidLicenseException(String, Throwable) - Constructor for exception io.confluent.license.InvalidLicenseException
io.confluent.license - package io.confluent.license
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
isAddonUpdatedWithSameExpiry(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.
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.
isTrial() - Method in class io.confluent.license.License: Determine whether the license represents a trial, such that the audience is simply "trial".
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 - 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() - Method in interface io.confluent.license.LicenseChanged: Get the license.
license() - Method in class io.confluent.license.LicenseManager.LicenseChangedEvent
license - Variable in class io.confluent.license.validator.LicenseConfig
License.DeploymentScope - Enum in io.confluent.license: Defines the deployment scope where a license can be used.
License.Type - Enum in io.confluent.license: Supported License Types:
LICENSE_PROP - Static variable in class io.confluent.license.validator.LicenseConfig
LicenseAddonTypes - Enum in io.confluent.license.util
LicenseAutoGenerationPolicy - Enum 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 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>, Supplier<LicenseTopicAdmin>, Callback<ConsumerRecord<K, V>>, Time, Consumer<LicenseTopicAdmin>, long) - 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>) - Constructor for class io.confluent.license.util.LicenseKafkaBasedLog: Create a new KafkaBasedLog object.
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.LicenseKafkaBasedLog(String, Map, Map, Supplier, Callback, Time, java.util.function.Consumer, long)
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.LicenseKafkaBasedLog(String, Map, Map, Supplier, Callback, Time, java.util.function.Consumer)
LicenseKeySerde() - Constructor for class io.confluent.license.LicenseStore.LicenseKeySerde
licenseLog - Variable in class io.confluent.license.LicenseStore
LicenseManager - Class in io.confluent.license: A license manager that can validate and store Confluent licenses in a topic in one Kafka cluster.
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(LicenseManager.ClusterClient, LicenseStore, Time) - Constructor for class io.confluent.license.LicenseManager
LicenseManager(LicenseManager.ClusterClient, LicenseStore, Time, LicenseManagerPurpose) - Constructor for class io.confluent.license.LicenseManager
LicenseManager(LicenseManager.ClusterClient, LicenseStore, Time, String, boolean, boolean) - Constructor for class io.confluent.license.LicenseManager
LicenseManager(LicenseManager.ClusterClient, LicenseStore, Time, String, boolean, boolean, LicenseManagerPurpose) - Constructor for class io.confluent.license.LicenseManager
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.BasicClusterClient - Class in io.confluent.license
LicenseManager.ClusterClient - Interface in io.confluent.license
LicenseManager.LicenseChangedEvent - Class in io.confluent.license
LicenseManager.LicenseStatus - Enum in io.confluent.license: License status enumeration for license validation operations
LicenseManagerPurpose - Enum 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
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(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>, List<Command.CommandKey>) - Constructor for class io.confluent.license.LicenseStore
LicenseStore(String, Map<String, Object>, Map<String, Object>, Map<String, Object>, Time) - Constructor for class io.confluent.license.LicenseStore
LicenseStore(String, Map<String, Object>, Map<String, Object>, Map<String, Object>, Time, List<Command.CommandKey>) - 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(List<Command.CommandKey>, String, ConcurrentHashMap<Command.CommandKey, String>, LicenseKafkaBasedLog<Command.CommandKey, Command.CommandMessage>, Time) - Constructor for class io.confluent.license.LicenseStore
LicenseStore(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(InputStream) - Static method in class io.confluent.license.License
loadPublicKey() - Static method in class io.confluent.license.LicenseManager

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
notifyLicense(License, License, List<License>, String) - Method in class io.confluent.license.LicenseManager

O

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

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
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
readLicense(PublicKey, String, boolean) - Method in class io.confluent.license.LicenseManager
readPartition(TopicPartition) - Method in class io.confluent.license.util.LicenseKafkaBasedLog: Signals whether a topic partition should be read by this log.
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.
readToEnd() - Method in class io.confluent.license.util.LicenseKafkaBasedLog: Same as LicenseKafkaBasedLog.readToEnd(Callback) but provides a Future instead of using a callback.
registerLicense(String) - Method in class io.confluent.license.LicenseStore: Supports single-license LicenseStore only.
registerLicense(String, Callback) - Method in class io.confluent.license.LicenseStore: Supports single-license LicenseStore only.
registerLicense(License.DeploymentScope, String) - Method in class io.confluent.license.LicenseStore: Registers a license JWT for the given License.DeploymentScope.
registerLicense(String) - Method in interface io.confluent.license.store.ConfluentLicenseStore
registerLicense(License.DeploymentScope, String) - Method in interface io.confluent.license.store.ConfluentLicenseStore
registerMetric(String) - Method in class io.confluent.license.validator.ConfluentLicenseValidator
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.
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

schedulePeriodicValidation() - Method in class io.confluent.license.validator.ConfluentLicenseValidator
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 - Class in io.confluent.license.util
Stage(String, long) - Constructor for class io.confluent.license.util.Stage
stage() - Method in exception io.confluent.license.util.StagedTimeoutException
StagedTimeoutException - Exception in io.confluent.license.util
StagedTimeoutException(Stage) - Constructor for exception 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(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() - Method in class io.confluent.license.LicenseStore
start() - Method in interface io.confluent.license.store.ConfluentLicenseStore
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(String) - Method in class io.confluent.license.validator.ConfluentLicenseValidator
started() - Method in class io.confluent.license.util.Stage
startLog() - Method in class io.confluent.license.LicenseStore
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.TrialOnlyLicenseManager
stop() - Method in class io.confluent.license.util.LicenseKafkaBasedLog
stopLog() - Method in class io.confluent.license.LicenseStore
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

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(long) - Method in class io.confluent.license.LicenseManager
timeUntilLicenseExpirationMs() - Method in class io.confluent.license.LicenseManager
topic() - Method in class io.confluent.license.LicenseStore
topic - Variable in class io.confluent.license.validator.LicenseConfig
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.LicenseManager.BasicClusterClient
toString() - Method in class io.confluent.license.LicenseManager.LicenseChangedEvent
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
TrialOnlyLicenseManager - Class in io.confluent.license: License manager for managing only trial licenses in Confluent Platform.
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.
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.
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.
type() - Method in class io.confluent.license.LicenseManager.LicenseChangedEvent

U

updatedAtMillis() - Method in class io.confluent.license.License
updateExpiredStatus(ConfluentLicenseValidator.LicenseStatus, Date) - Method in class io.confluent.license.validator.ConfluentLicenseValidator
updateInvalidStatus(String) - Method in class io.confluent.license.validator.ConfluentLicenseValidator
updateLicenseStatus(ConfluentLicenseValidator.LicenseStatus) - Method in class io.confluent.license.validator.ConfluentLicenseValidator

V

valueOf(String) - Static method in enum io.confluent.license.License.DeploymentScope: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.confluent.license.License.Type: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.confluent.license.LicenseAutoGenerationPolicy: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.confluent.license.LicenseChanged.Type: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.confluent.license.LicenseManager.LicenseStatus: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.confluent.license.LicenseManagerPurpose: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.confluent.license.util.LicenseAddonTypes: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.confluent.license.validator.ConfluentLicenseValidator.LicenseStatus: Returns the enum constant of this type with the specified name.
values() - Static method in enum io.confluent.license.License.DeploymentScope: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.confluent.license.License.Type: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.confluent.license.LicenseAutoGenerationPolicy: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.confluent.license.LicenseChanged.Type: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.confluent.license.LicenseManager.LicenseStatus: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.confluent.license.LicenseManagerPurpose: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.confluent.license.util.LicenseAddonTypes: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.confluent.license.validator.ConfluentLicenseValidator.LicenseStatus: Returns an array containing the constants of this enum type, in the order they are declared.
verify(PublicKey, String) - Static method in class io.confluent.license.License
verifyConfluentLicenseTopicMetadata(Consumer<Command.CommandKey, Command.CommandMessage>) - Method in class io.confluent.license.LicenseStore
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

WARN_THRESHOLD_DAYS - Static variable in class io.confluent.license.LicenseManager
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