All Classes and Interfaces

Class	Description
AddOffsetsToTxnRequestFilter	A stateless filter for AddOffsetsToTxnRequests.
AddOffsetsToTxnResponseFilter	A stateless filter for AddOffsetsToTxnResponses.
AddPartitionsToTxnRequestFilter	A stateless filter for AddPartitionsToTxnRequests.
AddPartitionsToTxnResponseFilter	A stateless filter for AddPartitionsToTxnResponses.
AddRaftVoterRequestFilter	A stateless filter for AddRaftVoterRequests.
AddRaftVoterResponseFilter	A stateless filter for AddRaftVoterResponses.
AllocateProducerIdsRequestFilter	A stateless filter for AllocateProducerIdsRequests.
AllocateProducerIdsResponseFilter	A stateless filter for AllocateProducerIdsResponses.
AllowDeny<T>	Class to keep track of allow and deny lists meant for use when building context for SSLEngine.
AlterClientQuotasRequestFilter	A stateless filter for AlterClientQuotasRequests.
AlterClientQuotasResponseFilter	A stateless filter for AlterClientQuotasResponses.
AlterConfigsRequestFilter	A stateless filter for AlterConfigsRequests.
AlterConfigsResponseFilter	A stateless filter for AlterConfigsResponses.
AlterPartitionReassignmentsRequestFilter	A stateless filter for AlterPartitionReassignmentsRequests.
AlterPartitionReassignmentsResponseFilter	A stateless filter for AlterPartitionReassignmentsResponses.
AlterPartitionRequestFilter	A stateless filter for AlterPartitionRequests.
AlterPartitionResponseFilter	A stateless filter for AlterPartitionResponses.
AlterReplicaLogDirsRequestFilter	A stateless filter for AlterReplicaLogDirsRequests.
AlterReplicaLogDirsResponseFilter	A stateless filter for AlterReplicaLogDirsResponses.
AlterShareGroupOffsetsRequestFilter	A stateless filter for AlterShareGroupOffsetsRequests.
AlterShareGroupOffsetsResponseFilter	A stateless filter for AlterShareGroupOffsetsResponses.
AlterUserScramCredentialsRequestFilter	A stateless filter for AlterUserScramCredentialsRequests.
AlterUserScramCredentialsResponseFilter	A stateless filter for AlterUserScramCredentialsResponses.
ApiVersionsRequestFilter	A stateless filter for ApiVersionsRequests.
ApiVersionsResponseFilter	A stateless filter for ApiVersionsResponses.
AssignReplicasToDirsRequestFilter	A stateless filter for AssignReplicasToDirsRequests.
AssignReplicasToDirsResponseFilter	A stateless filter for AssignReplicasToDirsResponses.
BeginQuorumEpochRequestFilter	A stateless filter for BeginQuorumEpochRequests.
BeginQuorumEpochResponseFilter	A stateless filter for BeginQuorumEpochResponses.
BrokerHeartbeatRequestFilter	A stateless filter for BrokerHeartbeatRequests.
BrokerHeartbeatResponseFilter	A stateless filter for BrokerHeartbeatResponses.
BrokerInfo	Broker metadata: host, port, and optional rack assignment.
BrokerRegistrationRequestFilter	A stateless filter for BrokerRegistrationRequests.
BrokerRegistrationResponseFilter	A stateless filter for BrokerRegistrationResponses.
ClientSaslContext	Exposes SASL authentication information to plugins, for example using FilterContext.clientSaslContext().
ClientTlsContext	Exposes TLS information about the client-to-proxy connection to plugins, for example using FilterContext.clientTlsContext().
CloseOrTerminalStage<R>	Interface supporting the FilterResultBuilder fluent API.
CloseOrTerminalStage	Combined stage of the RouterContext builder API that allows both closing the connection and building the result.
CloseStage<R>	Interface supporting the FilterResultBuilder fluent API.
CloseStage	Stage of the RouterContext builder API that allows requesting that the client connection be closed.
ConsumerGroupDescribeRequestFilter	A stateless filter for ConsumerGroupDescribeRequests.
ConsumerGroupDescribeResponseFilter	A stateless filter for ConsumerGroupDescribeResponses.
ConsumerGroupHeartbeatRequestFilter	A stateless filter for ConsumerGroupHeartbeatRequests.
ConsumerGroupHeartbeatResponseFilter	A stateless filter for ConsumerGroupHeartbeatResponses.
ControllerRegistrationRequestFilter	A stateless filter for ControllerRegistrationRequests.
ControllerRegistrationResponseFilter	A stateless filter for ControllerRegistrationResponses.
Coordinators	A snapshot of coordinator assignments, returned by TopologyService.coordinators(java.lang.String, byte, java.util.Set<java.lang.String>).
CreateAclsRequestFilter	A stateless filter for CreateAclsRequests.
CreateAclsResponseFilter	A stateless filter for CreateAclsResponses.
CreateDelegationTokenRequestFilter	A stateless filter for CreateDelegationTokenRequests.
CreateDelegationTokenResponseFilter	A stateless filter for CreateDelegationTokenResponses.
CreatePartitionsRequestFilter	A stateless filter for CreatePartitionsRequests.
CreatePartitionsResponseFilter	A stateless filter for CreatePartitionsResponses.
CreateTopicsRequestFilter	A stateless filter for CreateTopicsRequests.
CreateTopicsResponseFilter	A stateless filter for CreateTopicsResponses.
DeleteAclsRequestFilter	A stateless filter for DeleteAclsRequests.
DeleteAclsResponseFilter	A stateless filter for DeleteAclsResponses.
DeleteGroupsRequestFilter	A stateless filter for DeleteGroupsRequests.
DeleteGroupsResponseFilter	A stateless filter for DeleteGroupsResponses.
DeleteRecordsRequestFilter	A stateless filter for DeleteRecordsRequests.
DeleteRecordsResponseFilter	A stateless filter for DeleteRecordsResponses.
DeleteShareGroupOffsetsRequestFilter	A stateless filter for DeleteShareGroupOffsetsRequests.
DeleteShareGroupOffsetsResponseFilter	A stateless filter for DeleteShareGroupOffsetsResponses.
DeleteShareGroupStateRequestFilter	A stateless filter for DeleteShareGroupStateRequests.
DeleteShareGroupStateResponseFilter	A stateless filter for DeleteShareGroupStateResponses.
DeleteTopicsRequestFilter	A stateless filter for DeleteTopicsRequests.
DeleteTopicsResponseFilter	A stateless filter for DeleteTopicsResponses.
DeprecatedPluginName	Annotates a @Plugin implementation class whose fully-qualified type name has been changed and whose old name should no longer be used to refer to it.
DescribeAclsRequestFilter	A stateless filter for DescribeAclsRequests.
DescribeAclsResponseFilter	A stateless filter for DescribeAclsResponses.
DescribeClientQuotasRequestFilter	A stateless filter for DescribeClientQuotasRequests.
DescribeClientQuotasResponseFilter	A stateless filter for DescribeClientQuotasResponses.
DescribeClusterRequestFilter	A stateless filter for DescribeClusterRequests.
DescribeClusterResponseFilter	A stateless filter for DescribeClusterResponses.
DescribeConfigsRequestFilter	A stateless filter for DescribeConfigsRequests.
DescribeConfigsResponseFilter	A stateless filter for DescribeConfigsResponses.
DescribeDelegationTokenRequestFilter	A stateless filter for DescribeDelegationTokenRequests.
DescribeDelegationTokenResponseFilter	A stateless filter for DescribeDelegationTokenResponses.
DescribeGroupsRequestFilter	A stateless filter for DescribeGroupsRequests.
DescribeGroupsResponseFilter	A stateless filter for DescribeGroupsResponses.
DescribeLogDirsRequestFilter	A stateless filter for DescribeLogDirsRequests.
DescribeLogDirsResponseFilter	A stateless filter for DescribeLogDirsResponses.
DescribeProducersRequestFilter	A stateless filter for DescribeProducersRequests.
DescribeProducersResponseFilter	A stateless filter for DescribeProducersResponses.
DescribeQuorumRequestFilter	A stateless filter for DescribeQuorumRequests.
DescribeQuorumResponseFilter	A stateless filter for DescribeQuorumResponses.
DescribeShareGroupOffsetsRequestFilter	A stateless filter for DescribeShareGroupOffsetsRequests.
DescribeShareGroupOffsetsResponseFilter	A stateless filter for DescribeShareGroupOffsetsResponses.
DescribeTopicPartitionsRequestFilter	A stateless filter for DescribeTopicPartitionsRequests.
DescribeTopicPartitionsResponseFilter	A stateless filter for DescribeTopicPartitionsResponses.
DescribeTransactionsRequestFilter	A stateless filter for DescribeTransactionsRequests.
DescribeTransactionsResponseFilter	A stateless filter for DescribeTransactionsResponses.
DescribeUserScramCredentialsRequestFilter	A stateless filter for DescribeUserScramCredentialsRequests.
DescribeUserScramCredentialsResponseFilter	A stateless filter for DescribeUserScramCredentialsResponses.
ElectLeadersRequestFilter	A stateless filter for ElectLeadersRequests.
ElectLeadersResponseFilter	A stateless filter for ElectLeadersResponses.
EndQuorumEpochRequestFilter	A stateless filter for EndQuorumEpochRequests.
EndQuorumEpochResponseFilter	A stateless filter for EndQuorumEpochResponses.
EndTxnRequestFilter	A stateless filter for EndTxnRequests.
EndTxnResponseFilter	A stateless filter for EndTxnResponses.
EnvelopeRequestFilter	A stateless filter for EnvelopeRequests.
EnvelopeResponseFilter	A stateless filter for EnvelopeResponses.
ExpireDelegationTokenRequestFilter	A stateless filter for ExpireDelegationTokenRequests.
ExpireDelegationTokenResponseFilter	A stateless filter for ExpireDelegationTokenResponses.
FetchRequestFilter	A stateless filter for FetchRequests.
FetchResponseFilter	A stateless filter for FetchResponses.
FetchSnapshotRequestFilter	A stateless filter for FetchSnapshotRequests.
FetchSnapshotResponseFilter	A stateless filter for FetchSnapshotResponses.
FilePassword	A reference to the file containing a nonempty plain text password in UTF-8 encoding.
Filter	Marker interface all Filter interfaces extend from
FilterContext	A context to allow filters to interact with other filters and the pipeline.
FilterDispatchExecutor	An Executor backed by the Filter Dispatch Thread.
FilterFactory<C,I>	A pluggable source of Filter instances.
FilterFactoryContext	Construction context for Filters.
FilterResult	The result of a filter request or response operation that encapsulates the request or response to be forwarded to the next filter in the chain.
FilterResultBuilder<H,R>	Fluent builder for filter results.
FindCoordinatorRequestFilter	A stateless filter for FindCoordinatorRequests.
FindCoordinatorResponseFilter	A stateless filter for FindCoordinatorResponses.
GetTelemetrySubscriptionsRequestFilter	A stateless filter for GetTelemetrySubscriptionsRequests.
GetTelemetrySubscriptionsResponseFilter	A stateless filter for GetTelemetrySubscriptionsResponses.
HeartbeatRequestFilter	A stateless filter for HeartbeatRequests.
HeartbeatResponseFilter	A stateless filter for HeartbeatResponses.
IncrementalAlterConfigsRequestFilter	A stateless filter for IncrementalAlterConfigsRequests.
IncrementalAlterConfigsResponseFilter	A stateless filter for IncrementalAlterConfigsResponses.
InitializeShareGroupStateRequestFilter	A stateless filter for InitializeShareGroupStateRequests.
InitializeShareGroupStateResponseFilter	A stateless filter for InitializeShareGroupStateResponses.
InitProducerIdRequestFilter	A stateless filter for InitProducerIdRequests.
InitProducerIdResponseFilter	A stateless filter for InitProducerIdResponses.
InlinePassword	A password expressed directly in the model, in plain text.
InsecureTls	A TrustProvider that allows the disabling trust verification.
JoinGroupRequestFilter	A stateless filter for JoinGroupRequests.
JoinGroupResponseFilter	A stateless filter for JoinGroupResponses.
KeyPair	A KeyProvider backed by a private-key/certificate pair expressed in PEM format.
KeyProvider	A KeyProvider is a source of a TLS private-key/certificate pair and optionally intermediate certificate(s).
KeyProviderVisitor<T>	Visitor for implementations of KeyProvider
KeyStore	A KeyProvider backed by a Java Truststore.
LeaveGroupRequestFilter	A stateless filter for LeaveGroupRequests.
LeaveGroupResponseFilter	A stateless filter for LeaveGroupResponses.
ListConfigResourcesRequestFilter	A stateless filter for ListConfigResourcesRequests.
ListConfigResourcesResponseFilter	A stateless filter for ListConfigResourcesResponses.
ListGroupsRequestFilter	A stateless filter for ListGroupsRequests.
ListGroupsResponseFilter	A stateless filter for ListGroupsResponses.
ListOffsetsRequestFilter	A stateless filter for ListOffsetsRequests.
ListOffsetsResponseFilter	A stateless filter for ListOffsetsResponses.
ListPartitionReassignmentsRequestFilter	A stateless filter for ListPartitionReassignmentsRequests.
ListPartitionReassignmentsResponseFilter	A stateless filter for ListPartitionReassignmentsResponses.
ListTransactionsRequestFilter	A stateless filter for ListTransactionsRequests.
ListTransactionsResponseFilter	A stateless filter for ListTransactionsResponses.
MetadataRequestFilter	A stateless filter for MetadataRequests.
MetadataResponseFilter	A stateless filter for MetadataResponses.
OffsetCommitRequestFilter	A stateless filter for OffsetCommitRequests.
OffsetCommitResponseFilter	A stateless filter for OffsetCommitResponses.
OffsetDeleteRequestFilter	A stateless filter for OffsetDeleteRequests.
OffsetDeleteResponseFilter	A stateless filter for OffsetDeleteResponses.
OffsetFetchRequestFilter	A stateless filter for OffsetFetchRequests.
OffsetFetchResponseFilter	A stateless filter for OffsetFetchResponses.
OffsetForLeaderEpochRequestFilter	A stateless filter for OffsetForLeaderEpochRequests.
OffsetForLeaderEpochResponseFilter	A stateless filter for OffsetForLeaderEpochResponses.
PartitionInfo	Partition topology: leader, replicas, and in-sync replicas.
PartitionLeaders	A snapshot of partition leader assignments, returned by TopologyService.leaders(java.util.Map<java.lang.String, java.util.Set<java.lang.String>>).
PasswordProvider	A PasswordProvider is an abstract source of a password.
PlatformTrustProvider
Plugin	An annotation, on a plugin implementation class, that identifies the class of "config record" consumed by that implementation.
PluginConfigurationException	Thrown when a plugin configuration is invalid
PluginImplConfig	An annotation that identifies a plugin instance name at a plugin point within the configuration.
PluginImplName	Annotates a property (within a "config record") that names a plugin implementation with the plugin interface.
Plugins
Principal	An identifier held by a Subject.
PrincipalFactory<P>
ProduceRequestFilter	A stateless filter for ProduceRequests.
ProduceResponseFilter	A stateless filter for ProduceResponses.
PushTelemetryRequestFilter	A stateless filter for PushTelemetryRequests.
PushTelemetryResponseFilter	A stateless filter for PushTelemetryResponses.
ReadShareGroupStateRequestFilter	A stateless filter for ReadShareGroupStateRequests.
ReadShareGroupStateResponseFilter	A stateless filter for ReadShareGroupStateResponses.
ReadShareGroupStateSummaryRequestFilter	A stateless filter for ReadShareGroupStateSummaryRequests.
ReadShareGroupStateSummaryResponseFilter	A stateless filter for ReadShareGroupStateSummaryResponses.
RemoveRaftVoterRequestFilter	A stateless filter for RemoveRaftVoterRequests.
RemoveRaftVoterResponseFilter	A stateless filter for RemoveRaftVoterResponses.
RenewDelegationTokenRequestFilter	A stateless filter for RenewDelegationTokenRequests.
RenewDelegationTokenResponseFilter	A stateless filter for RenewDelegationTokenResponses.
RequestFilter	A Filter that handles all request types, for example to modify the request headers.
RequestFilterResult	A specialization of the FilterResult for request filters.
RequestFilterResultBuilder	Builder for request filter results.
ResponseFilter	A Filter that handles all response types.
ResponseFilterResult	A specialization of the FilterResult for response filters.
ResponseFilterResultBuilder	Builder for response filter results.
Router	A router decides which route should handle a given incoming Kafka request.
RouterContext	Context passed to Router.onRequest(org.apache.kafka.common.protocol.ApiKeys, short, org.apache.kafka.common.message.RequestHeaderData, org.apache.kafka.common.protocol.ApiMessage, io.kroxylicious.proxy.router.RouterContext) for issuing requests to named routes and constructing the routing outcome.
RouterFactory<C,I>	A pluggable source of Router instances.
RouterFactoryContext	Context for RouterFactory initialisation and router creation, providing access to the plugin registry and router identity.
RouterResponse	The outcome of Router.onRequest(org.apache.kafka.common.protocol.ApiKeys, short, org.apache.kafka.common.message.RequestHeaderData, org.apache.kafka.common.protocol.ApiMessage, io.kroxylicious.proxy.router.RouterContext) processing.
SaslAuthenticateRequestFilter	A stateless filter for SaslAuthenticateRequests.
SaslAuthenticateResponseFilter	A stateless filter for SaslAuthenticateResponses.
SaslHandshakeRequestFilter	A stateless filter for SaslHandshakeRequests.
SaslHandshakeResponseFilter	A stateless filter for SaslHandshakeResponses.
SaslSubjectBuilder	Builds a Subject based on information available from a successful SASL authentication.
SaslSubjectBuilder.Context	The context that's passed to SaslSubjectBuilder.buildSaslSubject(Context).
SaslSubjectBuilderService<C>
ServerOptions	Options that control TLS negotiation when in server mode.
ServerTlsCredentialSupplier	Supplies TLS credentials for proxy-to-server (upstream) TLS connections.
ServerTlsCredentialSupplierContext	Runtime context provided to ServerTlsCredentialSupplier instances when TLS credentials are requested.
ServerTlsCredentialSupplierFactory<C,I>	A pluggable factory for creating ServerTlsCredentialSupplier instances.
ServerTlsCredentialSupplierFactoryContext	Construction context for ServerTlsCredentialSupplier instances.
ShareAcknowledgeRequestFilter	A stateless filter for ShareAcknowledgeRequests.
ShareAcknowledgeResponseFilter	A stateless filter for ShareAcknowledgeResponses.
ShareFetchRequestFilter	A stateless filter for ShareFetchRequests.
ShareFetchResponseFilter	A stateless filter for ShareFetchResponses.
ShareGroupDescribeRequestFilter	A stateless filter for ShareGroupDescribeRequests.
ShareGroupDescribeResponseFilter	A stateless filter for ShareGroupDescribeResponses.
ShareGroupHeartbeatRequestFilter	A stateless filter for ShareGroupHeartbeatRequests.
ShareGroupHeartbeatResponseFilter	A stateless filter for ShareGroupHeartbeatResponses.
StreamsGroupDescribeRequestFilter	A stateless filter for StreamsGroupDescribeRequests.
StreamsGroupDescribeResponseFilter	A stateless filter for StreamsGroupDescribeResponses.
StreamsGroupHeartbeatRequestFilter	A stateless filter for StreamsGroupHeartbeatRequests.
StreamsGroupHeartbeatResponseFilter	A stateless filter for StreamsGroupHeartbeatResponses.
Subject	Represents an actor in the system.
SubjectBuildingException	An exception to be thrown if a Subject cannot be built.
SyncGroupRequestFilter	A stateless filter for SyncGroupRequests.
SyncGroupResponseFilter	A stateless filter for SyncGroupResponses.
TerminalStage<R>	Interface supporting the FilterResultBuilder fluent API.
TerminalStage	Terminal stage of the RouterContext builder API.
Tls	Provides TLS configuration for this peer.
TlsClientAuth
TlsCredentials	Represents TLS credentials (private key and certificate chain) that can be used for server-side TLS connections.
TlsCredentialSupplierConfig	Configuration for a TLS credential supplier that dynamically provides TLS credentials.
TopicLevelMetadataErrorException	Indicates that there was an Error set on a MetadataResponseData.MetadataResponseTopic.
TopicNameMapping	The result of discovering the topic names for a collection of topic ids
TopicNameMappingException	Indicates there was some problem obtaining a name for a topic id
TopLevelMetadataErrorException	Indicates that there was an Error set at the top level of MetadataResponseData.
TopologyService	Opt-in topology cache for routers that need leader, coordinator, broker, or topic ID information.
TransportSubjectBuilder	Builds a Subject based on information available at the transport layer, before any requests have been received from the client.
TransportSubjectBuilder.Context
TransportSubjectBuilderService<C>	The service interface used to construct a TransportSubjectBuilder.
TrustOptions
TrustProvider	A TrustProvider is a source of trust anchors used to determine whether a certificate present by a peer is trusted.
TrustProviderVisitor<T>	Visitor for implementations of TrustProvider
TrustStore	A TrustProvider backed by a Java Truststore.
TxnOffsetCommitRequestFilter	A stateless filter for TxnOffsetCommitRequests.
TxnOffsetCommitResponseFilter	A stateless filter for TxnOffsetCommitResponses.
Unique	Annotates implementations Principal which are only intended to have a single instance present in a Subject's principals.
UnknownPluginInstanceException	A reference to a plugin instance could not be resolved by the proxy runtime.
UnregisterBrokerRequestFilter	A stateless filter for UnregisterBrokerRequests.
UnregisterBrokerResponseFilter	A stateless filter for UnregisterBrokerResponses.
UpdateFeaturesRequestFilter	A stateless filter for UpdateFeaturesRequests.
UpdateFeaturesResponseFilter	A stateless filter for UpdateFeaturesResponses.
UpdateRaftVoterRequestFilter	A stateless filter for UpdateRaftVoterRequests.
UpdateRaftVoterResponseFilter	A stateless filter for UpdateRaftVoterResponses.
User	A principal identifying an authenticated client.
UserFactory
VirtualNode	Opaque reference to a node in the virtual cluster topology.
VoteRequestFilter	A stateless filter for VoteRequests.
VoteResponseFilter	A stateless filter for VoteResponses.
WriteShareGroupStateRequestFilter	A stateless filter for WriteShareGroupStateRequests.
WriteShareGroupStateResponseFilter	A stateless filter for WriteShareGroupStateResponses.
WriteTxnMarkersRequestFilter	A stateless filter for WriteTxnMarkersRequests.
WriteTxnMarkersResponseFilter	A stateless filter for WriteTxnMarkersResponses.