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

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 class io.confluent.license.LicenseManager
Add a listener for subsequent license changes.
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
 

C

close() - Method in class io.confluent.license.trial.ZkUtils
 
close() - Method in class io.confluent.license.validator.ConfluentLicenseValidator
 
configure(Map<String, ?>) - Method in class io.confluent.license.validator.ConfluentLicenseValidator
 
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 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
 
createLicenseManager(LicenseConfig) - Method in class io.confluent.license.validator.ConfluentLicenseValidator
 
createPersistentPath(String, String) - Method in class io.confluent.license.trial.ZkUtils
 

D

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

E

enabled() - Method in class io.confluent.license.validator.ConfluentLicenseValidator
 
equals(Object) - Method in class io.confluent.license.License
 
equals(Object) - Method in class io.confluent.license.LicenseManager.LicenseChangedEvent
 
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.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
 
expiresBefore(License) - Method in class io.confluent.license.License
Determine if this license expires before the specified license.

G

generateLicense(PublicKey, long) - Method in class io.confluent.license.LicenseManager
 
generateTrialLicense(JwtClaims) - Static method in class io.confluent.license.License
 
getAudience(JwtClaims) - Static method in class io.confluent.license.License
 
getExpiration(JwtClaims) - Static method in class io.confluent.license.License
 
getLicense() - Method in exception io.confluent.license.ExpiredLicenseException
 

H

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
 
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.trial - package io.confluent.license.trial
 
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
 
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.
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.
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.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.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() - 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.Type - Enum in io.confluent.license
The type of license.
LICENSE_PROP - Static variable in class io.confluent.license.validator.LicenseConfig
 
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
 
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(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>, Duration) - Constructor for class io.confluent.license.LicenseManager
 
LicenseManager(LicenseManager.ClusterClient, LicenseStore, Time) - 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
 
LicenseMessageSerde() - Constructor for class io.confluent.license.LicenseStore.LicenseMessageSerde
 
licenseScan() - Method in class io.confluent.license.LicenseStore
 
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>, Time) - Constructor for class io.confluent.license.LicenseStore
 
LicenseStore(String, Map<String, Object>, Map<String, Object>, Map<String, Object>, Duration, Time) - Constructor for class io.confluent.license.LicenseStore
 
LicenseStore(String, AtomicReference<String>, KafkaBasedLog<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
 
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
 
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
 

N

notifyLicense(License, 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
 

P

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
 
readStat(String) - Method in class io.confluent.license.trial.ZkUtils
 
registerLicense(String) - Method in class io.confluent.license.LicenseStore
 
registerLicense(String, Callback) - Method in class io.confluent.license.LicenseStore
 
registerMetric(String) - Method in class io.confluent.license.validator.ConfluentLicenseValidator
 
registerOrValidateLicense(String) - Method in class io.confluent.license.LicenseManager
Validate the supplied license, or if blank register a new trial license.
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
 

S

schedulePeriodicValidation() - Method in class io.confluent.license.validator.ConfluentLicenseValidator
 
serializedForm() - Method in class io.confluent.license.License
Get the serialized form of this license.
sign(PrivateKey, String, long, boolean) - Static method in class io.confluent.license.License
 
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(String) - Method in class io.confluent.license.validator.ConfluentLicenseValidator
 
startOrVerify(long) - Method in class io.confluent.license.trial.ZkTrialPeriod
Starts or verifies a trial period.
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
 
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.

T

timeRemaining(TimeUnit) - Method in class io.confluent.license.License
Get the amount of time in the specified units that remains before the license expires.
topic - 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
 
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.validator.LicenseConfig
 
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

updateExpiredStatus(ConfluentLicenseValidator.LicenseStatus, Date) - 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.Type
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.validator.ConfluentLicenseValidator.LicenseStatus
Returns the enum constant of this type with the specified name.
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.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.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
 
verifyMonitoring(JwtClaims) - Static method in class io.confluent.license.License
 
verifyStored(PublicKey, String) - Static method in class io.confluent.license.License
 

W

WARN_THRESHOLD_DAYS - Static variable in class io.confluent.license.LicenseManager
 

Z

ZkTrialPeriod - Class in io.confluent.license.trial
Keeps track of a users trial period, with the state information stored on zookeeper.
ZkTrialPeriod(String) - Constructor for class io.confluent.license.trial.ZkTrialPeriod
 
ZkTrialPeriod(String, String) - Constructor for class io.confluent.license.trial.ZkTrialPeriod
 
ZkUtils - Class in io.confluent.license.trial
 
ZkUtils(String, int, int, boolean) - Constructor for class io.confluent.license.trial.ZkUtils
 
A B C D E G H I L M N O P R S T U V W Z 
Skip navigation links