- 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
-
- LicenseKafkaBasedLog(String, Map<String, Object>, Map<String, Object>, Callback<ConsumerRecord<K, V>>, Time, Runnable) - Constructor for class io.confluent.license.util.LicenseKafkaBasedLog
-
- 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
-
- 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.