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 |
---|---|
static String |
MIN_INSYNC_REPLICAS_CONFIG |
static long |
READ_TO_END_TIMEOUT_MS |
static String |
REPLICATION_FACTOR_CONFIG |
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) |
Modifier and Type | Method and Description |
---|---|
String |
licenseScan() |
void |
registerLicense(String license) |
void |
registerLicense(String license,
org.apache.kafka.clients.producer.Callback callback) |
void |
start() |
void |
stop() |
String |
topic() |
public static final String REPLICATION_FACTOR_CONFIG
public static final String MIN_INSYNC_REPLICAS_CONFIG
public static final long READ_TO_END_TIMEOUT_MS
public LicenseStore(String topic, Map<String,Object> producerConfig, Map<String,Object> consumerConfig, Map<String,Object> topicConfig)
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()
public String licenseScan()
public void registerLicense(String license)
public void registerLicense(String license, org.apache.kafka.clients.producer.Callback callback)
public String topic()