public class ConfluentLicenseValidator extends java.lang.Object implements LicenseValidator, java.util.function.Consumer<LicenseChanged>
InvalidLicenseException
if the license is
invalid or has expired. The component using the license (e.g. broker) fails to start as
a result without a valid or free license. Thereafter, the component may continue to function
with proprietary features enabled even if license expires. In this case, an error is logged
periodically.Modifier and Type | Class and Description |
---|---|
static class |
ConfluentLicenseValidator.LicenseStatus |
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
METRIC_NAME |
Constructor and Description |
---|
ConfluentLicenseValidator(org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
void |
accept(LicenseChanged licenseChanged) |
void |
close() |
void |
configure(java.util.Map<java.lang.String,?> configs) |
protected LicenseManager |
createLicenseManager(LicenseConfig licenseConfig) |
void |
initializeAndVerify(java.lang.String license,
java.lang.String metricGroup,
java.lang.String componentId)
Initialize license using the provided license or free-tier/trial license.
|
protected void |
registerMetric(java.lang.String metricGroup) |
protected void |
updateExpiredStatus(ConfluentLicenseValidator.LicenseStatus status,
java.util.Date expirationDate) |
protected void |
updateLicenseStatus(ConfluentLicenseValidator.LicenseStatus status) |
boolean |
verifyLicense()
Verifies the registered license
|
public static final java.lang.String METRIC_NAME
public ConfluentLicenseValidator(org.apache.kafka.common.utils.Time time)
public void configure(java.util.Map<java.lang.String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public void initializeAndVerify(java.lang.String license, java.lang.String metricGroup, java.lang.String componentId) throws InvalidLicenseException
LicenseValidator
initializeAndVerify
in interface LicenseValidator
license
- License string which may be emptymetricGroup
- Metrics group for license statuscomponentId
- Component id included in client-ids of Kafka clients used by license managerInvalidLicenseException
- if license is invalid or has expiredpublic boolean verifyLicense()
LicenseValidator
verifyLicense
in interface LicenseValidator
public void accept(LicenseChanged licenseChanged)
accept
in interface java.util.function.Consumer<LicenseChanged>
public void close()
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
protected LicenseManager createLicenseManager(LicenseConfig licenseConfig)
protected void updateExpiredStatus(ConfluentLicenseValidator.LicenseStatus status, java.util.Date expirationDate)
protected void updateLicenseStatus(ConfluentLicenseValidator.LicenseStatus status)
protected void registerMetric(java.lang.String metricGroup)