JavaScript is disabled on your browser.
Skip navigation links
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
A
B
C
D
E
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 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
checkLicense()
- Method in class io.confluent.license.validator.
ConfluentLicenseValidator
close()
- Method in class io.confluent.license.validator.
ConfluentLicenseValidator
configure(Map<String, ?>)
- Method in class io.confluent.license.validator.
ConfluentLicenseValidator
configuredLicense()
- Method in class io.confluent.license.
LicenseManager
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
createConfluentLicenseTopic(AdminClient, String, NewTopic)
- Method in class io.confluent.license.
LicenseStore
createLicenseManager(LicenseConfig)
- Method in class io.confluent.license.validator.
ConfluentLicenseValidator
createLicenseStore(LicenseConfig)
- Method in class io.confluent.license.validator.
ConfluentLicenseValidator
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
getNextCheckIntervalMsAndMaybeLog(long)
- Method in class io.confluent.license.validator.
ConfluentLicenseValidator
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.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, 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, String, boolean, boolean)
- 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, Duration, 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
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
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
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
startLog()
- Method in class io.confluent.license.
LicenseStore
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
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.
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.
timeUntilLicenseExpirationMs(long)
- Method in class io.confluent.license.
LicenseManager
timeUntilLicenseExpirationMs()
- Method in class io.confluent.license.
LicenseManager
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
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
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.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
A
B
C
D
E
G
H
I
L
M
N
O
P
R
S
T
U
V
W
Skip navigation links
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes