public class LegacyLicenseValidator extends ConfluentLicenseValidator
ConfluentLicenseValidator.LicenseStatus
METRIC_NAME
Constructor and Description |
---|
LegacyLicenseValidator(org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
void |
configure(java.util.Map<java.lang.String,?> configs) |
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.
|
boolean |
verifyLicense()
Verifies the registered license
|
accept, close, createLicenseManager, registerMetric, updateExpiredStatus, updateLicenseStatus
public LegacyLicenseValidator(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
configure
in class ConfluentLicenseValidator
public void initializeAndVerify(java.lang.String license, java.lang.String metricGroup, java.lang.String componentId) throws InvalidLicenseException
LicenseValidator
initializeAndVerify
in interface LicenseValidator
initializeAndVerify
in class ConfluentLicenseValidator
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
verifyLicense
in class ConfluentLicenseValidator