public class LicenseStore extends 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 |
---|---|
protected org.apache.kafka.connect.util.KafkaBasedLog<io.confluent.command.record.Command.CommandKey,io.confluent.command.record.Command.CommandMessage> |
licenseLog |
static String |
MIN_INSYNC_REPLICAS_CONFIG |
static long |
READ_TO_END_TIMEOUT_MS |
static String |
REPLICATION_FACTOR_CONFIG |
Modifier | Constructor and Description |
---|---|
|
LicenseStore(String topic,
AtomicReference<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(String topic,
Map<String,Object> producerConfig,
Map<String,Object> consumerConfig,
Map<String,Object> topicConfig) |
|
LicenseStore(String topic,
Map<String,Object> producerConfig,
Map<String,Object> consumerConfig,
Map<String,Object> topicConfig,
Duration topicCreateTimeout,
Duration retryBackoffMinMs,
Duration retryBackoffMaxMs,
org.apache.kafka.common.utils.Time time) |
protected |
LicenseStore(String topic,
Map<String,Object> producerConfig,
Map<String,Object> consumerConfig,
Map<String,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,
String finalTopic,
org.apache.kafka.clients.admin.NewTopic topicDescription) |
String |
licenseScan() |
void |
registerLicense(String license) |
void |
registerLicense(String license,
org.apache.kafka.clients.producer.Callback callback) |
void |
start() |
protected void |
startLog() |
void |
stop() |
protected void |
stopLog() |
String |
topic() |
protected void |
verifyConfluentLicenseTopicMetadata(org.apache.kafka.clients.consumer.Consumer<io.confluent.command.record.Command.CommandKey,io.confluent.command.record.Command.CommandMessage> consumer) |
public static final String REPLICATION_FACTOR_CONFIG
public static final String MIN_INSYNC_REPLICAS_CONFIG
public static final long READ_TO_END_TIMEOUT_MS
protected final org.apache.kafka.connect.util.KafkaBasedLog<io.confluent.command.record.Command.CommandKey,io.confluent.command.record.Command.CommandMessage> licenseLog
public LicenseStore(String topic, Map<String,Object> producerConfig, Map<String,Object> consumerConfig, Map<String,Object> topicConfig)
protected LicenseStore(String topic, Map<String,Object> producerConfig, Map<String,Object> consumerConfig, Map<String,Object> topicConfig, org.apache.kafka.common.utils.Time time)
public LicenseStore(String topic, Map<String,Object> producerConfig, Map<String,Object> consumerConfig, Map<String,Object> topicConfig, Duration topicCreateTimeout, Duration retryBackoffMinMs, Duration retryBackoffMaxMs, org.apache.kafka.common.utils.Time time)
public LicenseStore(String topic, AtomicReference<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 String licenseScan()
public void registerLicense(String license)
public void registerLicense(String license, org.apache.kafka.clients.producer.Callback callback)
protected void createConfluentLicenseTopic(org.apache.kafka.clients.admin.AdminClient admin, String finalTopic, org.apache.kafka.clients.admin.NewTopic topicDescription)
protected void verifyConfluentLicenseTopicMetadata(org.apache.kafka.clients.consumer.Consumer<io.confluent.command.record.Command.CommandKey,io.confluent.command.record.Command.CommandMessage> consumer)
public String topic()