AdminClient |
The administrative client for Kafka, which supports managing and inspecting topics, brokers, configurations and ACLs.
|
AdminClientConfig |
The AdminClient configuration class, which also contains constants for configuration entry names.
|
AlterConfigsOptions |
|
AlterConfigsResult |
|
Config |
A configuration object containing the configuration entries for a resource.
|
ConfigEntry |
A class representing a configuration entry containing name, value and additional metadata.
|
CreateAclsOptions |
|
CreateAclsResult |
|
CreateTopicsOptions |
|
CreateTopicsResult |
|
DeleteAclsOptions |
|
DeleteAclsResult |
|
DeleteAclsResult.FilterResult |
A class containing either the deleted ACL binding or an exception if the delete failed.
|
DeleteAclsResult.FilterResults |
A class containing the results of the delete ACLs operation.
|
DeleteTopicsOptions |
|
DeleteTopicsResult |
|
DescribeAclsOptions |
|
DescribeAclsResult |
|
DescribeClusterOptions |
|
DescribeClusterResult |
|
DescribeConfigsOptions |
|
DescribeConfigsResult |
|
DescribeTopicsOptions |
|
DescribeTopicsResult |
|
KafkaAdminClient |
|
ListTopicsOptions |
|
ListTopicsResult |
|
NewTopic |
|
TopicDescription |
A detailed description of a single topic in the cluster.
|
TopicListing |
A listing of a topic in the cluster.
|