All Classes and Interfaces
Class
Description
A builder for
AlterBrokerReplicaExclusion.A builder for
Balancer.A builder for
BalancerAnyUnevenLoadStatus.An exception that indicates the Confluent Balancer component is not ready to process requests,
either because it is not enabled or because it has not managed to start yet.
An exception that indicates that the broker was not found to be registered in Kafka.
An exception that indicates a fetch Kafka broker operation has been attempted for a non existing
broker.
A builder for
BrokerRemoval.A builder for
BrokerReplicaExclusion.A builder for
BrokerSubTaskStatuses.A builder for
BrokerTask.Broker task type.
A builder for
CellState.A module to install the cloud specific controllers required by this application.
Following APIs are called only on the cloud UI, hence "internal".
An exception that indicates that the the authenticated user didn't have
CREATE access to
the resource.An exception that indicates that a cluster link already exists for the provided link name.
An exception that indicates that the cluster link doesn't exist.
A service to manage Kafka
TopicConfigs.REST application specific error codes.
A module to install the various controllers required by the application.
A feature that prevents unauthenticated users from starving Kafka REST of request handling
threads via produce calls.
A builder for
GroupConfig.Provides health-check functionality for this Kafka REST instance.
Represents the result of a service health check.
An exception that indicates a Kafka broker removal operation has been attempted for a invalid
broker.
An exception that indicates that the cluster link name is illegal
An exception that indicates that the config name is illegal
An exception indicating that the request body is invalid.
A service to manage
LastProducedTime.A builder for
LinkConfig.A service to manage Kafka links.
An exception that indicates that the mirror info is not available in the replica status output.
A service to manage Kafka mirrors.
An exception that indicates that the mirror topic doesn't exist.
A
CallbackHandler that recognizes OAuthBearerTokenCallback and retrieves OAuth 2
Bearer Token that was provided via the JAAS config.A service to manage
RemoveBrokerTask.A service to manage
ReplicaStatus.Enum representing the type of offset reset operation for share groups.
Exception thrown when attempting to use a producer that has been closed due to cache eviction.
Represents a Kafka Share Group.
A service to manage Kafka
Share Groups.Represents a Kafka Streams Group.
A service to manage Kafka
Streams Groups.Represents a Kafka Streams Group.
An exception that indicates that the AdminClient request timed out
An exception that indicates a fetch Kafka topic partition operation has been attempted for a non
existing topic partition.
Represents a TopicPartition with its associated offset and metadata.
Following APIs are called only on the cloud UI, hence "internal".
An exception that indicates the broker id is not unrepresentable or is invalid, e.g a negative
number.
An exception that indicates the underlying API is not supported by Kafka.