public class LicenseStore
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
LicenseStore.ConsumeCallback |
static class |
LicenseStore.LicenseKeySerde |
static class |
LicenseStore.LicenseMessageSerde |
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
MIN_INSYNC_REPLICAS_CONFIG |
static long |
READ_TO_END_TIMEOUT_MS |
static java.lang.String |
REPLICATION_FACTOR_CONFIG |
Modifier | Constructor and Description |
---|---|
|
LicenseStore(java.lang.String topic,
java.util.concurrent.atomic.AtomicReference<java.lang.String> latestLicense,
org.apache.kafka.connect.util.KafkaBasedLog<io.confluent.command.record.Command.CommandKey,io.confluent.command.record.Command.CommandMessage> licenseLog,
org.apache.kafka.common.utils.Time time) |
|
LicenseStore(java.lang.String topic,
java.util.Map<java.lang.String,java.lang.Object> producerConfig,
java.util.Map<java.lang.String,java.lang.Object> consumerConfig,
java.util.Map<java.lang.String,java.lang.Object> topicConfig) |
|
LicenseStore(java.lang.String topic,
java.util.Map<java.lang.String,java.lang.Object> producerConfig,
java.util.Map<java.lang.String,java.lang.Object> consumerConfig,
java.util.Map<java.lang.String,java.lang.Object> topicConfig,
java.time.Duration topicCreateTimeout,
java.time.Duration retryBackoffMinMs,
java.time.Duration retryBackoffMaxMs,
org.apache.kafka.common.utils.Time time) |
protected |
LicenseStore(java.lang.String topic,
java.util.Map<java.lang.String,java.lang.Object> producerConfig,
java.util.Map<java.lang.String,java.lang.Object> consumerConfig,
java.util.Map<java.lang.String,java.lang.Object> topicConfig,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
protected void |
createConfluentLicenseTopic(org.apache.kafka.clients.admin.AdminClient admin,
java.lang.String topic,
org.apache.kafka.clients.admin.NewTopic topicDescription) |
java.lang.String |
licenseScan() |
void |
registerLicense(java.lang.String license) |
void |
registerLicense(java.lang.String license,
org.apache.kafka.clients.producer.Callback callback) |
void |
start() |
protected void |
startLog() |
void |
stop() |
protected void |
stopLog() |
public static final java.lang.String REPLICATION_FACTOR_CONFIG
public static final java.lang.String MIN_INSYNC_REPLICAS_CONFIG
public static final long READ_TO_END_TIMEOUT_MS
public LicenseStore(java.lang.String topic, java.util.Map<java.lang.String,java.lang.Object> producerConfig, java.util.Map<java.lang.String,java.lang.Object> consumerConfig, java.util.Map<java.lang.String,java.lang.Object> topicConfig)
protected LicenseStore(java.lang.String topic, java.util.Map<java.lang.String,java.lang.Object> producerConfig, java.util.Map<java.lang.String,java.lang.Object> consumerConfig, java.util.Map<java.lang.String,java.lang.Object> topicConfig, org.apache.kafka.common.utils.Time time)
public LicenseStore(java.lang.String topic, java.util.Map<java.lang.String,java.lang.Object> producerConfig, java.util.Map<java.lang.String,java.lang.Object> consumerConfig, java.util.Map<java.lang.String,java.lang.Object> topicConfig, java.time.Duration topicCreateTimeout, java.time.Duration retryBackoffMinMs, java.time.Duration retryBackoffMaxMs, org.apache.kafka.common.utils.Time time)
public LicenseStore(java.lang.String topic, java.util.concurrent.atomic.AtomicReference<java.lang.String> latestLicense, org.apache.kafka.connect.util.KafkaBasedLog<io.confluent.command.record.Command.CommandKey,io.confluent.command.record.Command.CommandMessage> licenseLog, org.apache.kafka.common.utils.Time time)
public void start()
public void stop()
protected void startLog()
protected void stopLog()
public java.lang.String licenseScan()
public void registerLicense(java.lang.String license)
public void registerLicense(java.lang.String license, org.apache.kafka.clients.producer.Callback callback)
protected void createConfluentLicenseTopic(org.apache.kafka.clients.admin.AdminClient admin, java.lang.String topic, org.apache.kafka.clients.admin.NewTopic topicDescription)