All Classes and Interfaces
Class
Description
Exception thrown when there's an error during broker detection.
Interface for detecting Kafka broker type.
Enum representing different types of Kafka brokers that can be detected.
Generic interface for callbacks
Interface for Confluent license storage implementations.
License validator used by Kafka brokers for proprietary features.
An implementation of
ConvertingFutureCallback that doesn't do any conversion - i.e.this class provides utility functions and a cli for creating/verifying licenses
Defines the deployment scope where a license can be used.
Supported License Types:
Defines the automatic license generation policy when no valid license exists.
An event signaling that the license has changed.
The type of license change.
KafkaBasedLog provides a generic implementation of a shared, compacted log of records stored in Kafka that all
clients need to consume and, at times, agree on their offset / that they have read to the end of the log.
A license manager that can validate and store Confluent licenses in a topic in one Kafka cluster.
License status enumeration for license validation operations
A strategy class that accepts a lambda function to select a license from a list of licenses.
IMPORTANT: This class should not use Kafka APIs newer than AK 0.11.0/CP 3.3.0.
Utility to simplify creating and managing topics via the
Admin.A builder of
NewTopic instances.Simple string utilities, not present in java library, that are not worth importing a dependency.
License manager for managing only trial licenses in Confluent Platform.