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 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) |
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 |
---|---|
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() |
void |
stop() |
public static final java.lang.String REPLICATION_FACTOR_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.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()
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)