AbstractOptions<T extends AbstractOptions> |
|
AdminClient |
The base class for in-built admin clients.
|
AdminClientConfig |
The AdminClient configuration class, which also contains constants for configuration entry names.
|
AlterClientQuotasOptions |
|
AlterClientQuotasResult |
|
AlterConfigOp |
A class representing a alter configuration entry containing name, value and operation type.
|
AlterConfigsOptions |
|
AlterConfigsResult |
|
AlterConsumerGroupOffsetsOptions |
|
AlterConsumerGroupOffsetsResult |
|
AlterPartitionReassignmentsOptions |
|
AlterPartitionReassignmentsResult |
|
AlterReplicaLogDirsOptions |
|
AlterReplicaLogDirsResult |
|
AlterUserScramCredentialsOptions |
|
AlterUserScramCredentialsResult |
|
Config |
A configuration object containing the configuration entries for a resource.
|
ConfigEntry |
A class representing a configuration entry containing name, value and additional metadata.
|
ConfigEntry.ConfigSynonym |
Class representing a configuration synonym of a ConfigEntry .
|
ConsumerGroupDescription |
A detailed description of a single consumer group in the cluster.
|
ConsumerGroupListing |
A listing of a consumer group in the cluster.
|
CreateAclsOptions |
|
CreateAclsResult |
|
CreateDelegationTokenOptions |
|
CreateDelegationTokenResult |
|
CreatePartitionsOptions |
|
CreatePartitionsResult |
|
CreateTopicsOptions |
|
CreateTopicsResult |
|
CreateTopicsResult.TopicMetadataAndConfig |
|
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.
|
DeleteConsumerGroupOffsetsOptions |
|
DeleteConsumerGroupOffsetsResult |
|
DeleteConsumerGroupsOptions |
|
DeleteConsumerGroupsResult |
|
DeletedRecords |
Represents information about deleted records
The API for this class is still evolving and we may break compatibility in minor releases, if necessary.
|
DeleteRecordsOptions |
|
DeleteRecordsResult |
|
DeleteTopicsOptions |
|
DeleteTopicsResult |
|
DescribeAclsOptions |
|
DescribeAclsResult |
|
DescribeClientQuotasOptions |
|
DescribeClientQuotasResult |
|
DescribeClusterOptions |
|
DescribeClusterResult |
|
DescribeConfigsOptions |
|
DescribeConfigsResult |
|
DescribeConsumerGroupsOptions |
|
DescribeConsumerGroupsResult |
|
DescribeDelegationTokenOptions |
|
DescribeDelegationTokenResult |
|
DescribeFeaturesOptions |
|
DescribeFeaturesResult |
|
DescribeLogDirsOptions |
|
DescribeLogDirsResult |
|
DescribeReplicaLogDirsOptions |
|
DescribeReplicaLogDirsResult |
|
DescribeReplicaLogDirsResult.ReplicaLogDirInfo |
|
DescribeTopicsOptions |
|
DescribeTopicsResult |
|
DescribeUserScramCredentialsOptions |
|
DescribeUserScramCredentialsResult |
|
ElectLeadersOptions |
|
ElectLeadersResult |
|
ElectPreferredLeadersOptions |
Deprecated.
|
ElectPreferredLeadersResult |
Deprecated.
|
ExpireDelegationTokenOptions |
|
ExpireDelegationTokenResult |
|
FeatureMetadata |
Encapsulates details about finalized as well as supported features.
|
FeatureUpdate |
Encapsulates details about an update to a finalized feature.
|
FinalizedVersionRange |
Represents a range of version levels supported by every broker in a cluster for some feature.
|
KafkaAdminClient |
The default implementation of Admin .
|
ListConsumerGroupOffsetsOptions |
|
ListConsumerGroupOffsetsResult |
|
ListConsumerGroupsOptions |
|
ListConsumerGroupsResult |
|
ListOffsetsOptions |
|
ListOffsetsResult |
|
ListOffsetsResult.ListOffsetsResultInfo |
|
ListPartitionReassignmentsOptions |
|
ListPartitionReassignmentsResult |
|
ListTopicsOptions |
|
ListTopicsResult |
|
LogDirDescription |
A description of a log directory on a particular broker.
|
MemberAssignment |
A description of the assignments of a specific group member.
|
MemberDescription |
A detailed description of a single group instance in the cluster.
|
MemberToRemove |
A struct containing information about the member to be removed.
|
NewPartitionReassignment |
|
NewPartitions |
|
NewTopic |
|
OffsetSpec |
|
OffsetSpec.EarliestSpec |
|
OffsetSpec.LatestSpec |
|
OffsetSpec.TimestampSpec |
|
PartitionReassignment |
|
RecordsToDelete |
|
RemoveMembersFromConsumerGroupOptions |
|
RemoveMembersFromConsumerGroupResult |
|
RenewDelegationTokenOptions |
|
RenewDelegationTokenResult |
|
ReplicaInfo |
A description of a replica on a particular broker.
|
ScramCredentialInfo |
Mechanism and iterations for a SASL/SCRAM credential associated with a user.
|
SupportedVersionRange |
Represents a range of versions that a particular broker supports for some feature.
|
TopicDescription |
A detailed description of a single topic in the cluster.
|
TopicListing |
A listing of a topic in the cluster.
|
UnregisterBrokerOptions |
|
UnregisterBrokerResult |
|
UpdateFeaturesOptions |
|
UpdateFeaturesResult |
|
UserScramCredentialAlteration |
A request to alter a user's SASL/SCRAM credentials.
|
UserScramCredentialDeletion |
A request to delete a SASL/SCRAM credential for a user.
|
UserScramCredentialsDescription |
Representation of all SASL/SCRAM credentials associated with a user that can be retrieved, or an exception indicating
why credentials could not be retrieved.
|
UserScramCredentialUpsertion |
A request to update/insert a SASL/SCRAM credential for a user.
|