Package io.confluent.license

Class AddOnLicenseManagerImpl

java.lang.Object

io.confluent.license.AddOnLicenseManagerImpl

All Implemented Interfaces:

AddOnLicenseManager

public class AddOnLicenseManagerImpl
extends Object
implements AddOnLicenseManager

Constructor Summary

Constructors

Constructor	Description
AddOnLicenseManagerImpl(ConfluentLicenseStore store, LicenseManagerPurpose purpose, String licenseString, org.apache.kafka.common.utils.Time time)
AddOnLicenseManagerImpl(String topic, Map<String,Object> producerConfig, Map<String,Object> consumerConfig, Map<String,Object> topicConfig, LicenseManagerPurpose purpose, String licenseString)	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.

Method Summary

Modifier and Type	Method	Description
boolean	addListener(Consumer<LicenseChanged> listener)
License	registerOrValidateAddOnLicense(String license)
void	start()
void	stop()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AddOnLicenseManagerImpl

public AddOnLicenseManagerImpl(String topic,
 Map<String,Object> producerConfig,
 Map<String,Object> consumerConfig,
 Map<String,Object> topicConfig,
 LicenseManagerPurpose purpose,
 String licenseString)

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.

Parameters:

topic - the name of the topic where licenses are persisted; may not be null

producerConfig - the configuration for the producer used to write to the license topic; may not be null

consumerConfig - the configuration for the consumer used to read from the license topic; may not be null

topicConfig - the configuration for the admin client to create the license topic if required; may not be null

purpose - the purpose of license

licenseString - the license string, can be null if you want license to be fetched from kafka

AddOnLicenseManagerImpl

public AddOnLicenseManagerImpl(ConfluentLicenseStore store,
 LicenseManagerPurpose purpose,
 String licenseString,
 org.apache.kafka.common.utils.Time time)

Method Details

registerOrValidateAddOnLicense

public License registerOrValidateAddOnLicense(String license)
                                       throws InvalidLicenseException

Specified by:

registerOrValidateAddOnLicense in interface AddOnLicenseManager

Throws:

InvalidLicenseException

start

public void start()

Specified by:

start in interface AddOnLicenseManager

stop

public void stop()

Specified by:

stop in interface AddOnLicenseManager

addListener

public boolean addListener(Consumer<LicenseChanged> listener)

Specified by:

addListener in interface AddOnLicenseManager