Index

A B C D E F G H I J K L M N O P R S T U V W 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

accept(KeyProviderVisitor<T>) - Method in record class io.kroxylicious.proxy.config.tls.KeyPair
 
accept(KeyProviderVisitor<T>) - Method in interface io.kroxylicious.proxy.config.tls.KeyProvider
Visits the trust provider KeyProviderVisitor.
accept(KeyProviderVisitor<T>) - Method in record class io.kroxylicious.proxy.config.tls.KeyStore
 
accept(TrustProviderVisitor<T>) - Method in record class io.kroxylicious.proxy.config.tls.InsecureTls
 
accept(TrustProviderVisitor<T>) - Method in class io.kroxylicious.proxy.config.tls.PlatformTrustProvider
 
accept(TrustProviderVisitor<T>) - Method in interface io.kroxylicious.proxy.config.tls.TrustProvider
Visits the trust provider TrustProviderVisitor.
accept(TrustProviderVisitor<T>) - Method in record class io.kroxylicious.proxy.config.tls.TrustStore
 
AddOffsetsToTxnRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for AddOffsetsToTxnRequests.
AddOffsetsToTxnResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for AddOffsetsToTxnResponses.
AddPartitionsToTxnRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for AddPartitionsToTxnRequests.
AddPartitionsToTxnResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for AddPartitionsToTxnResponses.
AddRaftVoterRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for AddRaftVoterRequests.
AddRaftVoterResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for AddRaftVoterResponses.
allFailures() - Method in interface io.kroxylicious.proxy.filter.metadata.TopicNameMapping
 
AllocateProducerIdsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for AllocateProducerIdsRequests.
AllocateProducerIdsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for AllocateProducerIdsResponses.
AllowDeny<T> - Record Class in io.kroxylicious.proxy.config.tls
Class to keep track of allow and deny lists meant for use when building context for SSLEngine.
AllowDeny(List<T>, Set<T>) - Constructor for record class io.kroxylicious.proxy.config.tls.AllowDeny
Creates an instance of a AllowDeny record class.
allowed() - Method in record class io.kroxylicious.proxy.config.tls.AllowDeny
Returns the value of the allowed record component.
allowSharedClusterTargets() - Method in interface io.kroxylicious.proxy.router.RouterFactoryContext
Declares that this router supports routes targeting the same cluster.
allPrincipalsOfType(Class<P>) - Method in record class io.kroxylicious.proxy.authentication.Subject
Returns all principals of the given type.
AlterClientQuotasRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for AlterClientQuotasRequests.
AlterClientQuotasResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for AlterClientQuotasResponses.
AlterConfigsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for AlterConfigsRequests.
AlterConfigsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for AlterConfigsResponses.
AlterPartitionReassignmentsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for AlterPartitionReassignmentsRequests.
AlterPartitionReassignmentsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for AlterPartitionReassignmentsResponses.
AlterPartitionRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for AlterPartitionRequests.
AlterPartitionResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for AlterPartitionResponses.
AlterReplicaLogDirsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for AlterReplicaLogDirsRequests.
AlterReplicaLogDirsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for AlterReplicaLogDirsResponses.
AlterShareGroupOffsetsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for AlterShareGroupOffsetsRequests.
AlterShareGroupOffsetsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for AlterShareGroupOffsetsResponses.
AlterUserScramCredentialsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for AlterUserScramCredentialsRequests.
AlterUserScramCredentialsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for AlterUserScramCredentialsResponses.
anonymous() - Static method in record class io.kroxylicious.proxy.authentication.Subject
Returns the anonymous subject (no principals).
anyFailures() - Method in interface io.kroxylicious.proxy.filter.metadata.TopicNameMapping
 
anyNode(String) - Method in interface io.kroxylicious.proxy.router.RouterContext
Returns a virtual node that, when passed to RouterContext.sendRequest(io.kroxylicious.proxy.topology.VirtualNode, org.apache.kafka.common.message.RequestHeaderData, org.apache.kafka.common.protocol.ApiMessage), causes the runtime to send the request to an arbitrary broker on the named route's cluster.
ApiVersionsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ApiVersionsRequests.
ApiVersionsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ApiVersionsResponses.
AssignReplicasToDirsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for AssignReplicasToDirsRequests.
AssignReplicasToDirsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for AssignReplicasToDirsResponses.
authenticatedSubject() - Method in interface io.kroxylicious.proxy.filter.FilterContext
Returns the client subject.
authenticatedSubject() - Method in interface io.kroxylicious.proxy.router.RouterContext
Returns the client subject.
Authorization and cache scope - Search tag in interface io.kroxylicious.proxy.topology.TopologyService
Section
authorizationId() - Method in interface io.kroxylicious.proxy.authentication.ClientSaslContext
Returns the client's authorizationId that resulted from the SASL exchange.

B

BeginQuorumEpochRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for BeginQuorumEpochRequests.
BeginQuorumEpochResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for BeginQuorumEpochResponses.
BrokerHeartbeatRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for BrokerHeartbeatRequests.
BrokerHeartbeatResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for BrokerHeartbeatResponses.
brokerInfo(VirtualNode) - Method in interface io.kroxylicious.proxy.topology.TopologyService
Returns broker metadata (host, port, rack) for a virtual node, or empty if not cached.
BrokerInfo - Record Class in io.kroxylicious.proxy.topology
Broker metadata: host, port, and optional rack assignment.
BrokerInfo(String, int, String) - Constructor for record class io.kroxylicious.proxy.topology.BrokerInfo
Creates an instance of a BrokerInfo record class.
BrokerRegistrationRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for BrokerRegistrationRequests.
BrokerRegistrationResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for BrokerRegistrationResponses.
build() - Method in interface io.kroxylicious.proxy.authentication.SaslSubjectBuilderService
 
build() - Method in interface io.kroxylicious.proxy.authentication.TransportSubjectBuilderService
 
build() - Method in interface io.kroxylicious.proxy.filter.filterresultbuilder.TerminalStage
Constructs the filter result.
build() - Method in interface io.kroxylicious.proxy.router.TerminalStage
Constructs the router result.
buildSaslSubject(SaslSubjectBuilder.Context) - Method in interface io.kroxylicious.proxy.authentication.SaslSubjectBuilder
Returns an asynchronous result which completes with the Subject built from the given context.
buildTransportSubject(TransportSubjectBuilder.Context) - Method in interface io.kroxylicious.proxy.authentication.TransportSubjectBuilder
Returns an asynchronous result which completes with the Subject built from the given context.

C

Cache consistency and staleness - Search tag in interface io.kroxylicious.proxy.topology.TopologyService
Section
Cache population - Search tag in interface io.kroxylicious.proxy.topology.TopologyService
Section
Cache scope - Search tag in interface io.kroxylicious.proxy.topology.TopologyService
Section
certificateFile() - Method in record class io.kroxylicious.proxy.config.tls.KeyPair
Returns the value of the certificateFile record component.
Chained Computation stages - Search tag in io.kroxylicious.proxy.filter.FilterContext.sendRequest(RequestHeaderData, ApiMessage)
Section
Chained Computation stages - Search tag in io.kroxylicious.proxy.filter.FilterContext.topicNames(Collection<Uuid>)
Section
channelDescriptor() - Method in interface io.kroxylicious.proxy.filter.FilterContext
A description of the downstream/client channel.
cipherSuites() - Method in record class io.kroxylicious.proxy.config.tls.Tls
Returns the value of the cipherSuites record component.
clientAuth() - Method in record class io.kroxylicious.proxy.config.tls.ServerOptions
Returns the value of the clientAuth record component.
clientCertificate() - Method in interface io.kroxylicious.proxy.tls.ClientTlsContext
 
clientSaslAuthenticationFailure(String, String, Exception) - Method in interface io.kroxylicious.proxy.filter.FilterContext
Allows a filter (typically one which implements SaslAuthenticateRequestFilter) to announce a failed authentication outcome with the Kafka client.
clientSaslAuthenticationSuccess(String, Subject) - Method in interface io.kroxylicious.proxy.filter.FilterContext
Allows a filter (typically one which implements SaslAuthenticateRequestFilter) to announce a successful authentication outcome with the Kafka client to other plugins.
clientSaslContext() - Method in interface io.kroxylicious.proxy.authentication.SaslSubjectBuilder.Context
 
clientSaslContext() - Method in interface io.kroxylicious.proxy.filter.FilterContext
Returns the SASL context for the client connection.
ClientSaslContext - Interface in io.kroxylicious.proxy.authentication
Exposes SASL authentication information to plugins, for example using FilterContext.clientSaslContext().
clientTlsContext() - Method in interface io.kroxylicious.proxy.authentication.SaslSubjectBuilder.Context
 
clientTlsContext() - Method in interface io.kroxylicious.proxy.authentication.TransportSubjectBuilder.Context
 
clientTlsContext() - Method in interface io.kroxylicious.proxy.filter.FilterContext
Returns the TLS context for the client connection.
clientTlsContext() - Method in interface io.kroxylicious.proxy.tls.ServerTlsCredentialSupplierContext
Returns TLS information about the client-to-proxy connection, if available.
ClientTlsContext - Interface in io.kroxylicious.proxy.tls
Exposes TLS information about the client-to-proxy connection to plugins, for example using FilterContext.clientTlsContext().
close() - Method in interface io.kroxylicious.proxy.authentication.SaslSubjectBuilderService
 
close() - Method in interface io.kroxylicious.proxy.authentication.TransportSubjectBuilderService
 
close() - Method in interface io.kroxylicious.proxy.router.Router
Called by the runtime when the client connection is torn down.
close(I) - Method in interface io.kroxylicious.proxy.filter.FilterFactory
Called by the runtime to release any resources associated with the given initializationData.
close(I) - Method in interface io.kroxylicious.proxy.router.RouterFactory
Releases resources associated with the given initialisation data.
close(I) - Method in interface io.kroxylicious.proxy.tls.ServerTlsCredentialSupplierFactory
Called by the runtime to release any resources associated with the given initializationData.
closeConnection() - Method in interface io.kroxylicious.proxy.filter.FilterResult
signals the filter's wish that the connection will be closed. if the filter provides a message it will be forwarded before the connection is closed.
CloseOrTerminalStage<R> - Interface in io.kroxylicious.proxy.filter.filterresultbuilder
Interface supporting the FilterResultBuilder fluent API.
CloseOrTerminalStage - Interface in io.kroxylicious.proxy.router
Combined stage of the RouterContext builder API that allows both closing the connection and building the result.
CloseStage<R> - Interface in io.kroxylicious.proxy.filter.filterresultbuilder
Interface supporting the FilterResultBuilder fluent API.
CloseStage - Interface in io.kroxylicious.proxy.router
Stage of the RouterContext builder API that allows requesting that the client connection be closed.
completed() - Method in interface io.kroxylicious.proxy.filter.filterresultbuilder.TerminalStage
Produces the filter result contained within a completed CompletionStage.
completed() - Method in interface io.kroxylicious.proxy.router.TerminalStage
Produces the router result contained within a completed CompletionStage.
completeOnFilterDispatchThread(CompletionStage<T>) - Method in interface io.kroxylicious.proxy.filter.FilterDispatchExecutor
Switches to this Filter Dispatch Thread.
config() - Method in record class io.kroxylicious.proxy.config.tls.TlsCredentialSupplierConfig
Returns the value of the config record component.
configType() - Element in annotation interface io.kroxylicious.proxy.plugin.Plugin
 
Configuration Example - Search tag in interface io.kroxylicious.proxy.tls.ServerTlsCredentialSupplierFactory
Section
ConsumerGroupDescribeRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ConsumerGroupDescribeRequests.
ConsumerGroupDescribeResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ConsumerGroupDescribeResponses.
ConsumerGroupHeartbeatRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ConsumerGroupHeartbeatRequests.
ConsumerGroupHeartbeatResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ConsumerGroupHeartbeatResponses.
ControllerRegistrationRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ControllerRegistrationRequests.
ControllerRegistrationResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ControllerRegistrationResponses.
coordinatorFor(String) - Method in interface io.kroxylicious.proxy.topology.Coordinators
Returns the coordinator for the given key, or empty if the coordinator was not discovered (e.g. the group or transaction does not exist, or the coordinator is unavailable).
coordinators(String, byte, Set<String>) - Method in interface io.kroxylicious.proxy.topology.TopologyService
Discovers coordinators for the given keys on the given route, sending METADATA (if needed) then FIND_COORDINATOR.
Coordinators - Interface in io.kroxylicious.proxy.topology
create(ServerTlsCredentialSupplierFactoryContext, I) - Method in interface io.kroxylicious.proxy.tls.ServerTlsCredentialSupplierFactory
Creates an instance of ServerTlsCredentialSupplier.
CreateAclsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for CreateAclsRequests.
CreateAclsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for CreateAclsResponses.
createByteBufferOutputStream(int) - Method in interface io.kroxylicious.proxy.filter.FilterContext
Create a ByteBufferOutputStream of the given capacity.
CreateDelegationTokenRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for CreateDelegationTokenRequests.
CreateDelegationTokenResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for CreateDelegationTokenResponses.
createFilter(FilterFactoryContext, I) - Method in interface io.kroxylicious.proxy.filter.FilterFactory
Creates an instance of the Filter.
CreatePartitionsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for CreatePartitionsRequests.
CreatePartitionsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for CreatePartitionsResponses.
createRouter(RouterFactoryContext, I) - Method in interface io.kroxylicious.proxy.router.RouterFactory
Creates a new router instance.
CreateTopicsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for CreateTopicsRequests.
CreateTopicsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for CreateTopicsResponses.
Creating Filter Result objects - Search tag in package io.kroxylicious.proxy.filter
Section
credentialSupplier() - Method in record class io.kroxylicious.proxy.config.tls.Tls
Returns the value of the credentialSupplier record component.

D

Deferring Forwards - Search tag in package io.kroxylicious.proxy.filter
Section
definesKey() - Method in record class io.kroxylicious.proxy.config.tls.Tls
Returns whether a key provider is configured.
DeleteAclsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DeleteAclsRequests.
DeleteAclsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DeleteAclsResponses.
DeleteGroupsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DeleteGroupsRequests.
DeleteGroupsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DeleteGroupsResponses.
DeleteRecordsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DeleteRecordsRequests.
DeleteRecordsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DeleteRecordsResponses.
DeleteShareGroupOffsetsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DeleteShareGroupOffsetsRequests.
DeleteShareGroupOffsetsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DeleteShareGroupOffsetsResponses.
DeleteShareGroupStateRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DeleteShareGroupStateRequests.
DeleteShareGroupStateResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DeleteShareGroupStateResponses.
DeleteTopicsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DeleteTopicsRequests.
DeleteTopicsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DeleteTopicsResponses.
denied() - Method in record class io.kroxylicious.proxy.config.tls.AllowDeny
Returns the value of the denied record component.
DeprecatedPluginName - Annotation Interface in io.kroxylicious.proxy.plugin
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 - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeAclsRequests.
DescribeAclsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeAclsResponses.
DescribeClientQuotasRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeClientQuotasRequests.
DescribeClientQuotasResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeClientQuotasResponses.
DescribeClusterRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeClusterRequests.
DescribeClusterResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeClusterResponses.
DescribeConfigsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeConfigsRequests.
DescribeConfigsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeConfigsResponses.
DescribeDelegationTokenRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeDelegationTokenRequests.
DescribeDelegationTokenResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeDelegationTokenResponses.
DescribeGroupsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeGroupsRequests.
DescribeGroupsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeGroupsResponses.
DescribeLogDirsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeLogDirsRequests.
DescribeLogDirsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeLogDirsResponses.
DescribeProducersRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeProducersRequests.
DescribeProducersResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeProducersResponses.
DescribeQuorumRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeQuorumRequests.
DescribeQuorumResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeQuorumResponses.
DescribeShareGroupOffsetsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeShareGroupOffsetsRequests.
DescribeShareGroupOffsetsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeShareGroupOffsetsResponses.
DescribeTopicPartitionsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeTopicPartitionsRequests.
DescribeTopicPartitionsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeTopicPartitionsResponses.
DescribeTransactionsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeTransactionsRequests.
DescribeTransactionsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeTransactionsResponses.
DescribeUserScramCredentialsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeUserScramCredentialsRequests.
DescribeUserScramCredentialsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for DescribeUserScramCredentialsResponses.
Discovery methods - Search tag in interface io.kroxylicious.proxy.topology.TopologyService
Section
drop() - Method in interface io.kroxylicious.proxy.filter.FilterResult
signals the filter's wish that message is dropped i.e. not forwarded to the next filter in the chain.
drop() - Method in interface io.kroxylicious.proxy.filter.FilterResultBuilder
Signals the filter's wish that the message is dropped i.e. not forwarded to the next filter in the chain.

E

ElectLeadersRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ElectLeadersRequests.
ElectLeadersResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ElectLeadersResponses.
EMPTY - Static variable in interface io.kroxylicious.proxy.filter.metadata.TopicNameMapping
 
EndQuorumEpochRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for EndQuorumEpochRequests.
EndQuorumEpochResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for EndQuorumEpochResponses.
EndTxnRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for EndTxnRequests.
EndTxnResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for EndTxnResponses.
EnvelopeRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for EnvelopeRequests.
EnvelopeResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for EnvelopeResponses.
equals(Object) - Method in record class io.kroxylicious.proxy.authentication.Subject
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.authentication.User
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.secret.FilePassword
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.secret.InlinePassword
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.tls.AllowDeny
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.tls.InsecureTls
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.tls.KeyPair
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.tls.KeyStore
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.tls.ServerOptions
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.tls.Tls
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.tls.TlsCredentialSupplierConfig
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.tls.TrustStore
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.topology.BrokerInfo
Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.topology.PartitionInfo
Indicates whether some other object is "equal to" this one.
Error handling - Search tag in interface io.kroxylicious.proxy.router.RouterContext
Section
Error Handling - Search tag in interface io.kroxylicious.proxy.tls.ServerTlsCredentialSupplier
Section
errorResponse(RequestHeaderData, ApiMessage, ApiException) - Method in interface io.kroxylicious.proxy.filter.RequestFilterResultBuilder
Generate a short-circuit error response towards the client.
ExpireDelegationTokenRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ExpireDelegationTokenRequests.
ExpireDelegationTokenResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ExpireDelegationTokenResponses.

F

failures() - Method in interface io.kroxylicious.proxy.filter.metadata.TopicNameMapping
Describes the reason for every failed mapping.
FetchRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for FetchRequests.
FetchResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for FetchResponses.
FetchSnapshotRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for FetchSnapshotRequests.
FetchSnapshotResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for FetchSnapshotResponses.
FilePassword - Record Class in io.kroxylicious.proxy.config.secret
A reference to the file containing a nonempty plain text password in UTF-8 encoding.
FilePassword(String) - Constructor for record class io.kroxylicious.proxy.config.secret.FilePassword
Creates an instance of a FilePassword record class.
Filter - Interface in io.kroxylicious.proxy.filter
Marker interface all Filter interfaces extend from
FilterContext - Interface in io.kroxylicious.proxy.filter
A context to allow filters to interact with other filters and the pipeline.
filterDispatchExecutor() - Method in interface io.kroxylicious.proxy.filter.FilterFactoryContext
An executor backed by the single Thread responsible for dispatching work to a Filter instance for a channel.
filterDispatchExecutor() - Method in interface io.kroxylicious.proxy.tls.ServerTlsCredentialSupplierFactoryContext
Returns the filter dispatch executor for asynchronous operations.
FilterDispatchExecutor - Interface in io.kroxylicious.proxy.filter
An Executor backed by the Filter Dispatch Thread.
FilterFactory<C,I> - Interface in io.kroxylicious.proxy.filter
A pluggable source of Filter instances.
FilterFactoryContext - Interface in io.kroxylicious.proxy.filter
Construction context for Filters.
Filtering - Search tag in io.kroxylicious.proxy.filter.FilterContext.sendRequest(RequestHeaderData, ApiMessage)
Section
FilterResult - Interface in io.kroxylicious.proxy.filter
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> - Interface in io.kroxylicious.proxy.filter
Fluent builder for filter results.
Filter Results - Search tag in package io.kroxylicious.proxy.filter
Section
FindCoordinatorRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for FindCoordinatorRequests.
FindCoordinatorResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for FindCoordinatorResponses.
forClient() - Method in record class io.kroxylicious.proxy.config.tls.ServerOptions
 
forClient() - Method in interface io.kroxylicious.proxy.config.tls.TrustOptions
 
forward(H, ApiMessage) - Method in interface io.kroxylicious.proxy.filter.FilterResultBuilder
A forward of a request or response message to the next filter in the chain.
forwardRequest(RequestHeaderData, ApiMessage) - Method in interface io.kroxylicious.proxy.filter.FilterContext
Generates a completed filter results containing the given header and request.
forwardResponse(ResponseHeaderData, ApiMessage) - Method in interface io.kroxylicious.proxy.filter.FilterContext
Generates a completed filter results containing the given header and response.

G

getError() - Method in exception class io.kroxylicious.proxy.filter.metadata.TopicNameMappingException
 
getProvidedPassword() - Method in record class io.kroxylicious.proxy.config.secret.FilePassword
 
getProvidedPassword() - Method in record class io.kroxylicious.proxy.config.secret.InlinePassword
 
getProvidedPassword() - Method in interface io.kroxylicious.proxy.config.secret.PasswordProvider
 
getStoreTypeOrPlatformDefault(String) - Static method in record class io.kroxylicious.proxy.config.tls.Tls
Returns the store type, defaulting to the platform default if null.
GetTelemetrySubscriptionsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for GetTelemetrySubscriptionsRequests.
GetTelemetrySubscriptionsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for GetTelemetrySubscriptionsResponses.
getType() - Method in record class io.kroxylicious.proxy.config.tls.KeyStore
 
getType() - Method in record class io.kroxylicious.proxy.config.tls.TrustStore
 
getVirtualClusterName() - Method in interface io.kroxylicious.proxy.filter.FilterContext
Allows the filter to identify which cluster it is processing a request for

H

hashCode() - Method in record class io.kroxylicious.proxy.authentication.Subject
Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.authentication.User
Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.secret.FilePassword
Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.secret.InlinePassword
Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.tls.AllowDeny
Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.tls.InsecureTls
Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.tls.KeyPair
Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.tls.KeyStore
Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.tls.ServerOptions
Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.tls.Tls
Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.tls.TlsCredentialSupplierConfig
Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.tls.TrustStore
Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.topology.BrokerInfo
Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.topology.PartitionInfo
Returns a hash code value for this object.
header() - Method in interface io.kroxylicious.proxy.filter.FilterResult
the header to be forwarded to the next filter in the chain.
Header - Search tag in io.kroxylicious.proxy.filter.FilterContext.sendRequest(RequestHeaderData, ApiMessage)
Section
HeartbeatRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for HeartbeatRequests.
HeartbeatResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for HeartbeatResponses.
host() - Method in record class io.kroxylicious.proxy.topology.BrokerInfo
Returns the value of the host record component.

I

Implementing a plugin - Search tag in package io.kroxylicious.proxy.plugin
Section
Implementing Filters - Search tag in package io.kroxylicious.proxy.filter
Section
implNameProperty() - Element in annotation interface io.kroxylicious.proxy.plugin.PluginImplConfig
 
Important facts about the Kafka protocol - Search tag in package io.kroxylicious.proxy.filter
Section
IncrementalAlterConfigsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for IncrementalAlterConfigsRequests.
IncrementalAlterConfigsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for IncrementalAlterConfigsResponses.
initialize(C) - Method in interface io.kroxylicious.proxy.authentication.SaslSubjectBuilderService
 
initialize(C) - Method in interface io.kroxylicious.proxy.authentication.TransportSubjectBuilderService
 
initialize(FilterFactoryContext, C) - Method in interface io.kroxylicious.proxy.filter.FilterFactory
Initializes the factory with the specified configuration.
initialize(RouterFactoryContext, C) - Method in interface io.kroxylicious.proxy.router.RouterFactory
Initializes the factory with the given configuration.
initialize(ServerTlsCredentialSupplierFactoryContext, C) - Method in interface io.kroxylicious.proxy.tls.ServerTlsCredentialSupplierFactory
Initializes the factory with the specified configuration.
InitializeShareGroupStateRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for InitializeShareGroupStateRequests.
InitializeShareGroupStateResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for InitializeShareGroupStateResponses.
InitProducerIdRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for InitProducerIdRequests.
InitProducerIdResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for InitProducerIdResponses.
InlinePassword - Record Class in io.kroxylicious.proxy.config.secret
A password expressed directly in the model, in plain text.
InlinePassword(String) - Constructor for record class io.kroxylicious.proxy.config.secret.InlinePassword
Creates an instance of a InlinePassword record class.
insecure() - Method in record class io.kroxylicious.proxy.config.tls.InsecureTls
Returns the value of the insecure record component.
InsecureTls - Record Class in io.kroxylicious.proxy.config.tls
A TrustProvider that allows the disabling trust verification.
InsecureTls(boolean) - Constructor for record class io.kroxylicious.proxy.config.tls.InsecureTls
Creates an instance of a InsecureTls record class.
INSTANCE - Static variable in class io.kroxylicious.proxy.config.tls.PlatformTrustProvider
 
invalidateRoute(String) - Method in interface io.kroxylicious.proxy.topology.TopologyService
Coarse invalidation: clears all partition info, coordinators, broker info, and topic ID to name mappings for a route.
io.kroxylicious.proxy.authentication - package io.kroxylicious.proxy.authentication
APIs for plugins that provide or consume SASL authentication outcomes.
io.kroxylicious.proxy.config.secret - package io.kroxylicious.proxy.config.secret
Abstraction for providing passwords to proxy configuration.
io.kroxylicious.proxy.config.tls - package io.kroxylicious.proxy.config.tls
TLS configuration for proxy connections to clients and upstream clusters.
io.kroxylicious.proxy.filter - package io.kroxylicious.proxy.filter
The protocol filter API.
io.kroxylicious.proxy.filter.filterresultbuilder - package io.kroxylicious.proxy.filter.filterresultbuilder
Builder API for constructing filter results.
io.kroxylicious.proxy.filter.metadata - package io.kroxylicious.proxy.filter.metadata
APIs for resolving topic IDs to topic names and handling metadata-related errors.
io.kroxylicious.proxy.plugin - package io.kroxylicious.proxy.plugin
API for defining plugins within configuration.
io.kroxylicious.proxy.router - package io.kroxylicious.proxy.router
The router API.
io.kroxylicious.proxy.tls - package io.kroxylicious.proxy.tls
APIs for plugins that are exposed to details of TLS connections between the proxy and its network peers.
io.kroxylicious.proxy.topology - package io.kroxylicious.proxy.topology
Topology types: cluster structure, node identity, and topology caching for routers (and potentially filters).
isAnonymous() - Method in record class io.kroxylicious.proxy.authentication.Subject
Returns whether this is the anonymous subject.
isInFilterDispatchThread() - Method in interface io.kroxylicious.proxy.filter.FilterDispatchExecutor
 
isPemType() - Method in record class io.kroxylicious.proxy.config.tls.KeyStore
 
isPemType() - Method in record class io.kroxylicious.proxy.config.tls.TrustStore
 
isr() - Method in record class io.kroxylicious.proxy.topology.PartitionInfo
Returns the value of the isr record component.

J

JoinGroupRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for JoinGroupRequests.
JoinGroupResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for JoinGroupResponses.

K

key() - Method in record class io.kroxylicious.proxy.config.tls.Tls
Returns the value of the key record component.
KeyPair - Record Class in io.kroxylicious.proxy.config.tls
A KeyProvider backed by a private-key/certificate pair expressed in PEM format.
KeyPair(String, String, PasswordProvider) - Constructor for record class io.kroxylicious.proxy.config.tls.KeyPair
Creates an instance of a KeyPair record class.
keyPasswordProvider() - Method in record class io.kroxylicious.proxy.config.tls.KeyPair
Returns the value of the keyPasswordProvider record component.
keyPasswordProvider() - Method in record class io.kroxylicious.proxy.config.tls.KeyStore
Returns the value of the keyPasswordProvider record component.
KeyProvider - Interface in io.kroxylicious.proxy.config.tls
A KeyProvider is a source of a TLS private-key/certificate pair and optionally intermediate certificate(s).
KeyProviderVisitor<T> - Interface in io.kroxylicious.proxy.config.tls
Visitor for implementations of KeyProvider
KeyStore - Record Class in io.kroxylicious.proxy.config.tls
A KeyProvider backed by a Java Truststore.
KeyStore(String, PasswordProvider, PasswordProvider, String) - Constructor for record class io.kroxylicious.proxy.config.tls.KeyStore
Creates an instance of a KeyStore record class.

L

leader() - Method in record class io.kroxylicious.proxy.topology.PartitionInfo
Returns the value of the leader record component.
leaderOf(String, int) - Method in interface io.kroxylicious.proxy.topology.PartitionLeaders
Returns the leader for the given topic-partition, or empty if the leader was not discovered (e.g. the topic does not exist, or the partition has no leader).
leaders(Map<String, Set<String>>) - Method in interface io.kroxylicious.proxy.topology.TopologyService
Discovers partition leaders for the given topics on the given routes, sending METADATA requests as needed.
LeaveGroupRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for LeaveGroupRequests.
LeaveGroupResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for LeaveGroupResponses.
Lifecycle - Search tag in interface io.kroxylicious.proxy.tls.ServerTlsCredentialSupplierFactory
Section
Lifecycle scope - Search tag in interface io.kroxylicious.proxy.filter.FilterFactory
Section
ListConfigResourcesRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ListConfigResourcesRequests.
ListConfigResourcesResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ListConfigResourcesResponses.
ListGroupsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ListGroupsRequests.
ListGroupsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ListGroupsResponses.
ListOffsetsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ListOffsetsRequests.
ListOffsetsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ListOffsetsResponses.
ListPartitionReassignmentsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ListPartitionReassignmentsRequests.
ListPartitionReassignmentsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ListPartitionReassignmentsResponses.
ListTransactionsRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ListTransactionsRequests.
ListTransactionsResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ListTransactionsResponses.
Local view - Search tag in package io.kroxylicious.proxy.filter
Section

M

mechanismName() - Method in interface io.kroxylicious.proxy.authentication.ClientSaslContext
The name of the SASL mechanism used.
message() - Method in interface io.kroxylicious.proxy.filter.FilterResult
the message to be forwarded to the next filter in the chain.
MetadataRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for MetadataRequests.
MetadataResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for MetadataResponses.

N

name() - Method in interface io.kroxylicious.proxy.authentication.Principal
 
name() - Method in record class io.kroxylicious.proxy.authentication.User
Returns the value of the name record component.
newPrincipal(String) - Method in interface io.kroxylicious.proxy.authentication.PrincipalFactory
 
newPrincipal(String) - Method in class io.kroxylicious.proxy.authentication.UserFactory
 
nodeForId(int) - Method in interface io.kroxylicious.proxy.router.RouterContext
Converts an integer node ID from a protocol response body into a VirtualNode.
Non-Blocking Requirement - Search tag in interface io.kroxylicious.proxy.tls.ServerTlsCredentialSupplier
Section
NONE - Enum constant in enum class io.kroxylicious.proxy.config.tls.TlsClientAuth
 

O

Observability guidelines for router implementations - Search tag in interface io.kroxylicious.proxy.router.Router
Section
OffsetCommitRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for OffsetCommitRequests.
OffsetCommitResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for OffsetCommitResponses.
OffsetDeleteRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for OffsetDeleteRequests.
OffsetDeleteResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for OffsetDeleteResponses.
OffsetFetchRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for OffsetFetchRequests.
OffsetFetchResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for OffsetFetchResponses.
OffsetForLeaderEpochRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for OffsetForLeaderEpochRequests.
OffsetForLeaderEpochResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for OffsetForLeaderEpochResponses.
oldName() - Element in annotation interface io.kroxylicious.proxy.plugin.DeprecatedPluginName
The fully qualified class name by which this plugin was previously known.
onAddOffsetsToTxnRequest(short, RequestHeaderData, AddOffsetsToTxnRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.AddOffsetsToTxnRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onAddOffsetsToTxnResponse(short, ResponseHeaderData, AddOffsetsToTxnResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.AddOffsetsToTxnResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onAddPartitionsToTxnRequest(short, RequestHeaderData, AddPartitionsToTxnRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.AddPartitionsToTxnRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onAddPartitionsToTxnResponse(short, ResponseHeaderData, AddPartitionsToTxnResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.AddPartitionsToTxnResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onAddRaftVoterRequest(short, RequestHeaderData, AddRaftVoterRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.AddRaftVoterRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onAddRaftVoterResponse(short, ResponseHeaderData, AddRaftVoterResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.AddRaftVoterResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onAllocateProducerIdsRequest(short, RequestHeaderData, AllocateProducerIdsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.AllocateProducerIdsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onAllocateProducerIdsResponse(short, ResponseHeaderData, AllocateProducerIdsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.AllocateProducerIdsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onAlterClientQuotasRequest(short, RequestHeaderData, AlterClientQuotasRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.AlterClientQuotasRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onAlterClientQuotasResponse(short, ResponseHeaderData, AlterClientQuotasResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.AlterClientQuotasResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onAlterConfigsRequest(short, RequestHeaderData, AlterConfigsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.AlterConfigsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onAlterConfigsResponse(short, ResponseHeaderData, AlterConfigsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.AlterConfigsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onAlterPartitionReassignmentsRequest(short, RequestHeaderData, AlterPartitionReassignmentsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.AlterPartitionReassignmentsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onAlterPartitionReassignmentsResponse(short, ResponseHeaderData, AlterPartitionReassignmentsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.AlterPartitionReassignmentsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onAlterPartitionRequest(short, RequestHeaderData, AlterPartitionRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.AlterPartitionRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onAlterPartitionResponse(short, ResponseHeaderData, AlterPartitionResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.AlterPartitionResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onAlterReplicaLogDirsRequest(short, RequestHeaderData, AlterReplicaLogDirsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.AlterReplicaLogDirsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onAlterReplicaLogDirsResponse(short, ResponseHeaderData, AlterReplicaLogDirsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.AlterReplicaLogDirsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onAlterShareGroupOffsetsRequest(short, RequestHeaderData, AlterShareGroupOffsetsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.AlterShareGroupOffsetsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onAlterShareGroupOffsetsResponse(short, ResponseHeaderData, AlterShareGroupOffsetsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.AlterShareGroupOffsetsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onAlterUserScramCredentialsRequest(short, RequestHeaderData, AlterUserScramCredentialsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.AlterUserScramCredentialsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onAlterUserScramCredentialsResponse(short, ResponseHeaderData, AlterUserScramCredentialsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.AlterUserScramCredentialsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onApiVersionsRequest(short, RequestHeaderData, ApiVersionsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ApiVersionsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onApiVersionsResponse(short, ResponseHeaderData, ApiVersionsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ApiVersionsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onAssignReplicasToDirsRequest(short, RequestHeaderData, AssignReplicasToDirsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.AssignReplicasToDirsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onAssignReplicasToDirsResponse(short, ResponseHeaderData, AssignReplicasToDirsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.AssignReplicasToDirsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onBeginQuorumEpochRequest(short, RequestHeaderData, BeginQuorumEpochRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.BeginQuorumEpochRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onBeginQuorumEpochResponse(short, ResponseHeaderData, BeginQuorumEpochResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.BeginQuorumEpochResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onBrokerHeartbeatRequest(short, RequestHeaderData, BrokerHeartbeatRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.BrokerHeartbeatRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onBrokerHeartbeatResponse(short, ResponseHeaderData, BrokerHeartbeatResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.BrokerHeartbeatResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onBrokerRegistrationRequest(short, RequestHeaderData, BrokerRegistrationRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.BrokerRegistrationRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onBrokerRegistrationResponse(short, ResponseHeaderData, BrokerRegistrationResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.BrokerRegistrationResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onConsumerGroupDescribeRequest(short, RequestHeaderData, ConsumerGroupDescribeRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ConsumerGroupDescribeRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onConsumerGroupDescribeResponse(short, ResponseHeaderData, ConsumerGroupDescribeResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ConsumerGroupDescribeResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onConsumerGroupHeartbeatRequest(short, RequestHeaderData, ConsumerGroupHeartbeatRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ConsumerGroupHeartbeatRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onConsumerGroupHeartbeatResponse(short, ResponseHeaderData, ConsumerGroupHeartbeatResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ConsumerGroupHeartbeatResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onControllerRegistrationRequest(short, RequestHeaderData, ControllerRegistrationRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ControllerRegistrationRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onControllerRegistrationResponse(short, ResponseHeaderData, ControllerRegistrationResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ControllerRegistrationResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onCreateAclsRequest(short, RequestHeaderData, CreateAclsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.CreateAclsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onCreateAclsResponse(short, ResponseHeaderData, CreateAclsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.CreateAclsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onCreateDelegationTokenRequest(short, RequestHeaderData, CreateDelegationTokenRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.CreateDelegationTokenRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onCreateDelegationTokenResponse(short, ResponseHeaderData, CreateDelegationTokenResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.CreateDelegationTokenResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onCreatePartitionsRequest(short, RequestHeaderData, CreatePartitionsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.CreatePartitionsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onCreatePartitionsResponse(short, ResponseHeaderData, CreatePartitionsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.CreatePartitionsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onCreateTopicsRequest(short, RequestHeaderData, CreateTopicsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.CreateTopicsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onCreateTopicsResponse(short, ResponseHeaderData, CreateTopicsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.CreateTopicsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onDeleteAclsRequest(short, RequestHeaderData, DeleteAclsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DeleteAclsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onDeleteAclsResponse(short, ResponseHeaderData, DeleteAclsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DeleteAclsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onDeleteGroupsRequest(short, RequestHeaderData, DeleteGroupsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DeleteGroupsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onDeleteGroupsResponse(short, ResponseHeaderData, DeleteGroupsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DeleteGroupsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onDeleteRecordsRequest(short, RequestHeaderData, DeleteRecordsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DeleteRecordsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onDeleteRecordsResponse(short, ResponseHeaderData, DeleteRecordsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DeleteRecordsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onDeleteShareGroupOffsetsRequest(short, RequestHeaderData, DeleteShareGroupOffsetsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DeleteShareGroupOffsetsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onDeleteShareGroupOffsetsResponse(short, ResponseHeaderData, DeleteShareGroupOffsetsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DeleteShareGroupOffsetsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onDeleteShareGroupStateRequest(short, RequestHeaderData, DeleteShareGroupStateRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DeleteShareGroupStateRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onDeleteShareGroupStateResponse(short, ResponseHeaderData, DeleteShareGroupStateResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DeleteShareGroupStateResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onDeleteTopicsRequest(short, RequestHeaderData, DeleteTopicsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DeleteTopicsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onDeleteTopicsResponse(short, ResponseHeaderData, DeleteTopicsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DeleteTopicsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onDescribeAclsRequest(short, RequestHeaderData, DescribeAclsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeAclsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onDescribeAclsResponse(short, ResponseHeaderData, DescribeAclsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeAclsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onDescribeClientQuotasRequest(short, RequestHeaderData, DescribeClientQuotasRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeClientQuotasRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onDescribeClientQuotasResponse(short, ResponseHeaderData, DescribeClientQuotasResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeClientQuotasResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onDescribeClusterRequest(short, RequestHeaderData, DescribeClusterRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeClusterRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onDescribeClusterResponse(short, ResponseHeaderData, DescribeClusterResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeClusterResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onDescribeConfigsRequest(short, RequestHeaderData, DescribeConfigsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeConfigsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onDescribeConfigsResponse(short, ResponseHeaderData, DescribeConfigsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeConfigsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onDescribeDelegationTokenRequest(short, RequestHeaderData, DescribeDelegationTokenRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeDelegationTokenRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onDescribeDelegationTokenResponse(short, ResponseHeaderData, DescribeDelegationTokenResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeDelegationTokenResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onDescribeGroupsRequest(short, RequestHeaderData, DescribeGroupsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeGroupsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onDescribeGroupsResponse(short, ResponseHeaderData, DescribeGroupsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeGroupsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onDescribeLogDirsRequest(short, RequestHeaderData, DescribeLogDirsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeLogDirsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onDescribeLogDirsResponse(short, ResponseHeaderData, DescribeLogDirsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeLogDirsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onDescribeProducersRequest(short, RequestHeaderData, DescribeProducersRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeProducersRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onDescribeProducersResponse(short, ResponseHeaderData, DescribeProducersResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeProducersResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onDescribeQuorumRequest(short, RequestHeaderData, DescribeQuorumRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeQuorumRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onDescribeQuorumResponse(short, ResponseHeaderData, DescribeQuorumResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeQuorumResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onDescribeShareGroupOffsetsRequest(short, RequestHeaderData, DescribeShareGroupOffsetsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeShareGroupOffsetsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onDescribeShareGroupOffsetsResponse(short, ResponseHeaderData, DescribeShareGroupOffsetsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeShareGroupOffsetsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onDescribeTopicPartitionsRequest(short, RequestHeaderData, DescribeTopicPartitionsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeTopicPartitionsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onDescribeTopicPartitionsResponse(short, ResponseHeaderData, DescribeTopicPartitionsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeTopicPartitionsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onDescribeTransactionsRequest(short, RequestHeaderData, DescribeTransactionsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeTransactionsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onDescribeTransactionsResponse(short, ResponseHeaderData, DescribeTransactionsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeTransactionsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onDescribeUserScramCredentialsRequest(short, RequestHeaderData, DescribeUserScramCredentialsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeUserScramCredentialsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onDescribeUserScramCredentialsResponse(short, ResponseHeaderData, DescribeUserScramCredentialsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.DescribeUserScramCredentialsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onElectLeadersRequest(short, RequestHeaderData, ElectLeadersRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ElectLeadersRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onElectLeadersResponse(short, ResponseHeaderData, ElectLeadersResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ElectLeadersResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onEndQuorumEpochRequest(short, RequestHeaderData, EndQuorumEpochRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.EndQuorumEpochRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onEndQuorumEpochResponse(short, ResponseHeaderData, EndQuorumEpochResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.EndQuorumEpochResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onEndTxnRequest(short, RequestHeaderData, EndTxnRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.EndTxnRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onEndTxnResponse(short, ResponseHeaderData, EndTxnResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.EndTxnResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onEnvelopeRequest(short, RequestHeaderData, EnvelopeRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.EnvelopeRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onEnvelopeResponse(short, ResponseHeaderData, EnvelopeResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.EnvelopeResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onExpireDelegationTokenRequest(short, RequestHeaderData, ExpireDelegationTokenRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ExpireDelegationTokenRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onExpireDelegationTokenResponse(short, ResponseHeaderData, ExpireDelegationTokenResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ExpireDelegationTokenResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onFetchRequest(short, RequestHeaderData, FetchRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.FetchRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onFetchResponse(short, ResponseHeaderData, FetchResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.FetchResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onFetchSnapshotRequest(short, RequestHeaderData, FetchSnapshotRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.FetchSnapshotRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onFetchSnapshotResponse(short, ResponseHeaderData, FetchSnapshotResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.FetchSnapshotResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onFindCoordinatorRequest(short, RequestHeaderData, FindCoordinatorRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.FindCoordinatorRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onFindCoordinatorResponse(short, ResponseHeaderData, FindCoordinatorResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.FindCoordinatorResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onGetTelemetrySubscriptionsRequest(short, RequestHeaderData, GetTelemetrySubscriptionsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.GetTelemetrySubscriptionsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onGetTelemetrySubscriptionsResponse(short, ResponseHeaderData, GetTelemetrySubscriptionsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.GetTelemetrySubscriptionsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onHeartbeatRequest(short, RequestHeaderData, HeartbeatRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.HeartbeatRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onHeartbeatResponse(short, ResponseHeaderData, HeartbeatResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.HeartbeatResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onIncrementalAlterConfigsRequest(short, RequestHeaderData, IncrementalAlterConfigsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.IncrementalAlterConfigsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onIncrementalAlterConfigsResponse(short, ResponseHeaderData, IncrementalAlterConfigsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.IncrementalAlterConfigsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onInitializeShareGroupStateRequest(short, RequestHeaderData, InitializeShareGroupStateRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.InitializeShareGroupStateRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onInitializeShareGroupStateResponse(short, ResponseHeaderData, InitializeShareGroupStateResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.InitializeShareGroupStateResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onInitProducerIdRequest(short, RequestHeaderData, InitProducerIdRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.InitProducerIdRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onInitProducerIdResponse(short, ResponseHeaderData, InitProducerIdResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.InitProducerIdResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onJoinGroupRequest(short, RequestHeaderData, JoinGroupRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.JoinGroupRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onJoinGroupResponse(short, ResponseHeaderData, JoinGroupResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.JoinGroupResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onLeaveGroupRequest(short, RequestHeaderData, LeaveGroupRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.LeaveGroupRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onLeaveGroupResponse(short, ResponseHeaderData, LeaveGroupResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.LeaveGroupResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onListConfigResourcesRequest(short, RequestHeaderData, ListConfigResourcesRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ListConfigResourcesRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onListConfigResourcesResponse(short, ResponseHeaderData, ListConfigResourcesResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ListConfigResourcesResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onListGroupsRequest(short, RequestHeaderData, ListGroupsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ListGroupsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onListGroupsResponse(short, ResponseHeaderData, ListGroupsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ListGroupsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onListOffsetsRequest(short, RequestHeaderData, ListOffsetsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ListOffsetsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onListOffsetsResponse(short, ResponseHeaderData, ListOffsetsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ListOffsetsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onListPartitionReassignmentsRequest(short, RequestHeaderData, ListPartitionReassignmentsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ListPartitionReassignmentsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onListPartitionReassignmentsResponse(short, ResponseHeaderData, ListPartitionReassignmentsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ListPartitionReassignmentsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onListTransactionsRequest(short, RequestHeaderData, ListTransactionsRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ListTransactionsRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onListTransactionsResponse(short, ResponseHeaderData, ListTransactionsResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ListTransactionsResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onMetadataRequest(short, RequestHeaderData, MetadataRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.MetadataRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onMetadataResponse(short, ResponseHeaderData, MetadataResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.MetadataResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onOffsetCommitRequest(short, RequestHeaderData, OffsetCommitRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.OffsetCommitRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onOffsetCommitResponse(short, ResponseHeaderData, OffsetCommitResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.OffsetCommitResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onOffsetDeleteRequest(short, RequestHeaderData, OffsetDeleteRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.OffsetDeleteRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onOffsetDeleteResponse(short, ResponseHeaderData, OffsetDeleteResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.OffsetDeleteResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onOffsetFetchRequest(short, RequestHeaderData, OffsetFetchRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.OffsetFetchRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onOffsetFetchResponse(short, ResponseHeaderData, OffsetFetchResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.OffsetFetchResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onOffsetForLeaderEpochRequest(short, RequestHeaderData, OffsetForLeaderEpochRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.OffsetForLeaderEpochRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onOffsetForLeaderEpochResponse(short, ResponseHeaderData, OffsetForLeaderEpochResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.OffsetForLeaderEpochResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onProduceRequest(short, RequestHeaderData, ProduceRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ProduceRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onProduceResponse(short, ResponseHeaderData, ProduceResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ProduceResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onPushTelemetryRequest(short, RequestHeaderData, PushTelemetryRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.PushTelemetryRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onPushTelemetryResponse(short, ResponseHeaderData, PushTelemetryResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.PushTelemetryResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onReadShareGroupStateRequest(short, RequestHeaderData, ReadShareGroupStateRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ReadShareGroupStateRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onReadShareGroupStateResponse(short, ResponseHeaderData, ReadShareGroupStateResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ReadShareGroupStateResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onReadShareGroupStateSummaryRequest(short, RequestHeaderData, ReadShareGroupStateSummaryRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ReadShareGroupStateSummaryRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onReadShareGroupStateSummaryResponse(short, ResponseHeaderData, ReadShareGroupStateSummaryResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ReadShareGroupStateSummaryResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onRemoveRaftVoterRequest(short, RequestHeaderData, RemoveRaftVoterRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.RemoveRaftVoterRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onRemoveRaftVoterResponse(short, ResponseHeaderData, RemoveRaftVoterResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.RemoveRaftVoterResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onRenewDelegationTokenRequest(short, RequestHeaderData, RenewDelegationTokenRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.RenewDelegationTokenRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onRenewDelegationTokenResponse(short, ResponseHeaderData, RenewDelegationTokenResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.RenewDelegationTokenResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in interface io.kroxylicious.proxy.filter.RequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, RouterContext) - Method in interface io.kroxylicious.proxy.router.Router
Called for each incoming client request that is dynamically routed.
onRequest(ApiKeys, RequestHeaderData, ApiMessage, FilterContext) - Method in interface io.kroxylicious.proxy.filter.RequestFilter
Deprecated, for removal: This API element is subject to removal in a future version.
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onResponse(ApiKeys, ResponseHeaderData, ApiMessage, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ResponseFilter
Deprecated, for removal: This API element is subject to removal in a future version.
onSaslAuthenticateRequest(short, RequestHeaderData, SaslAuthenticateRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.SaslAuthenticateRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onSaslAuthenticateResponse(short, ResponseHeaderData, SaslAuthenticateResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.SaslAuthenticateResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onSaslHandshakeRequest(short, RequestHeaderData, SaslHandshakeRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.SaslHandshakeRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onSaslHandshakeResponse(short, ResponseHeaderData, SaslHandshakeResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.SaslHandshakeResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onShareAcknowledgeRequest(short, RequestHeaderData, ShareAcknowledgeRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ShareAcknowledgeRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onShareAcknowledgeResponse(short, ResponseHeaderData, ShareAcknowledgeResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ShareAcknowledgeResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onShareFetchRequest(short, RequestHeaderData, ShareFetchRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ShareFetchRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onShareFetchResponse(short, ResponseHeaderData, ShareFetchResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ShareFetchResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onShareGroupDescribeRequest(short, RequestHeaderData, ShareGroupDescribeRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ShareGroupDescribeRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onShareGroupDescribeResponse(short, ResponseHeaderData, ShareGroupDescribeResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ShareGroupDescribeResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onShareGroupHeartbeatRequest(short, RequestHeaderData, ShareGroupHeartbeatRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ShareGroupHeartbeatRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onShareGroupHeartbeatResponse(short, ResponseHeaderData, ShareGroupHeartbeatResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.ShareGroupHeartbeatResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onStreamsGroupDescribeRequest(short, RequestHeaderData, StreamsGroupDescribeRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.StreamsGroupDescribeRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onStreamsGroupDescribeResponse(short, ResponseHeaderData, StreamsGroupDescribeResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.StreamsGroupDescribeResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onStreamsGroupHeartbeatRequest(short, RequestHeaderData, StreamsGroupHeartbeatRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.StreamsGroupHeartbeatRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onStreamsGroupHeartbeatResponse(short, ResponseHeaderData, StreamsGroupHeartbeatResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.StreamsGroupHeartbeatResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onSyncGroupRequest(short, RequestHeaderData, SyncGroupRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.SyncGroupRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onSyncGroupResponse(short, ResponseHeaderData, SyncGroupResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.SyncGroupResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onTxnOffsetCommitRequest(short, RequestHeaderData, TxnOffsetCommitRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.TxnOffsetCommitRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onTxnOffsetCommitResponse(short, ResponseHeaderData, TxnOffsetCommitResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.TxnOffsetCommitResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onUnregisterBrokerRequest(short, RequestHeaderData, UnregisterBrokerRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.UnregisterBrokerRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onUnregisterBrokerResponse(short, ResponseHeaderData, UnregisterBrokerResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.UnregisterBrokerResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onUpdateFeaturesRequest(short, RequestHeaderData, UpdateFeaturesRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.UpdateFeaturesRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onUpdateFeaturesResponse(short, ResponseHeaderData, UpdateFeaturesResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.UpdateFeaturesResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onUpdateRaftVoterRequest(short, RequestHeaderData, UpdateRaftVoterRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.UpdateRaftVoterRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onUpdateRaftVoterResponse(short, ResponseHeaderData, UpdateRaftVoterResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.UpdateRaftVoterResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onVoteRequest(short, RequestHeaderData, VoteRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.VoteRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onVoteResponse(short, ResponseHeaderData, VoteResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.VoteResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onWriteShareGroupStateRequest(short, RequestHeaderData, WriteShareGroupStateRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.WriteShareGroupStateRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onWriteShareGroupStateResponse(short, ResponseHeaderData, WriteShareGroupStateResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.WriteShareGroupStateResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
onWriteTxnMarkersRequest(short, RequestHeaderData, WriteTxnMarkersRequestData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.WriteTxnMarkersRequestFilter
Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
onWriteTxnMarkersResponse(short, ResponseHeaderData, WriteTxnMarkersResponseData, FilterContext) - Method in interface io.kroxylicious.proxy.filter.WriteTxnMarkersResponseFilter
Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
Ordering - Search tag in package io.kroxylicious.proxy.filter
Section

P

partitionInfo(String, int) - Method in interface io.kroxylicious.proxy.topology.TopologyService
Returns full partition info (leader, replicas, ISR) for a topic-partition, or empty if not cached.
PartitionInfo - Record Class in io.kroxylicious.proxy.topology
Partition topology: leader, replicas, and in-sync replicas.
PartitionInfo(VirtualNode, List<VirtualNode>, List<VirtualNode>) - Constructor for record class io.kroxylicious.proxy.topology.PartitionInfo
Defensive-copies the replica and ISR lists.
PartitionLeaders - Interface in io.kroxylicious.proxy.topology
password() - Method in record class io.kroxylicious.proxy.config.secret.InlinePassword
Returns the value of the password record component.
passwordFile() - Method in record class io.kroxylicious.proxy.config.secret.FilePassword
Returns the value of the passwordFile record component.
PasswordProvider - Interface in io.kroxylicious.proxy.config.secret
A PasswordProvider is an abstract source of a password.
PEM - Static variable in record class io.kroxylicious.proxy.config.tls.Tls
 
Pipelining - Search tag in package io.kroxylicious.proxy.filter
Section
PlatformTrustProvider - Class in io.kroxylicious.proxy.config.tls
 
Plugin - Annotation Interface in io.kroxylicious.proxy.plugin
An annotation, on a plugin implementation class, that identifies the class of "config record" consumed by that implementation.
Plugin Composition - Search tag in interface io.kroxylicious.proxy.tls.ServerTlsCredentialSupplierFactoryContext
Section
PluginConfigurationException - Exception Class in io.kroxylicious.proxy.plugin
Thrown when a plugin configuration is invalid
PluginConfigurationException(String) - Constructor for exception class io.kroxylicious.proxy.plugin.PluginConfigurationException
Initializes a new instance
PluginConfigurationException(String, Throwable) - Constructor for exception class io.kroxylicious.proxy.plugin.PluginConfigurationException
Initializes a new instance
PluginImplConfig - Annotation Interface in io.kroxylicious.proxy.plugin
An annotation that identifies a plugin instance name at a plugin point within the configuration.
pluginImplementationNames(Class<P>) - Method in interface io.kroxylicious.proxy.filter.FilterFactoryContext
Returns the implementation names of the registered instances of this plugin.
pluginImplementationNames(Class<P>) - Method in interface io.kroxylicious.proxy.router.RouterFactoryContext
Returns the implementation names of the registered instances of the given plugin type.
pluginImplementationNames(Class<P>) - Method in interface io.kroxylicious.proxy.tls.ServerTlsCredentialSupplierFactoryContext
Returns the implementation names of all registered instances of a plugin type.
PluginImplName - Annotation Interface in io.kroxylicious.proxy.plugin
Annotates a property (within a "config record") that names a plugin implementation with the plugin interface.
pluginInstance(Class<P>, String) - Method in interface io.kroxylicious.proxy.filter.FilterFactoryContext
Gets a plugin instance for the given plugin type and name
pluginInstance(Class<P>, String) - Method in interface io.kroxylicious.proxy.router.RouterFactoryContext
Gets a plugin instance for the given plugin type and name.
pluginInstance(Class<P>, String) - Method in interface io.kroxylicious.proxy.tls.ServerTlsCredentialSupplierFactoryContext
Gets a plugin instance for the given plugin type and implementation name.
Plugins - Class in io.kroxylicious.proxy.plugin
 
port() - Method in record class io.kroxylicious.proxy.topology.BrokerInfo
Returns the value of the port record component.
Principal - Interface in io.kroxylicious.proxy.authentication
An identifier held by a Subject.
PrincipalFactory<P> - Interface in io.kroxylicious.proxy.authentication
 
principals() - Method in record class io.kroxylicious.proxy.authentication.Subject
Returns the value of the principals record component.
privateKeyFile() - Method in record class io.kroxylicious.proxy.config.tls.KeyPair
Returns the value of the privateKeyFile record component.
ProduceRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ProduceRequests.
ProduceResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ProduceResponses.
protocols() - Method in record class io.kroxylicious.proxy.config.tls.Tls
Returns the value of the protocols record component.
proxyServerCertificate() - Method in interface io.kroxylicious.proxy.tls.ClientTlsContext
 
PushTelemetryRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for PushTelemetryRequests.
PushTelemetryResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for PushTelemetryResponses.

R

rack() - Method in record class io.kroxylicious.proxy.topology.BrokerInfo
Returns the value of the rack record component.
ReadShareGroupStateRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ReadShareGroupStateRequests.
ReadShareGroupStateResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ReadShareGroupStateResponses.
ReadShareGroupStateSummaryRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ReadShareGroupStateSummaryRequests.
ReadShareGroupStateSummaryResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ReadShareGroupStateSummaryResponses.
RemoveRaftVoterRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for RemoveRaftVoterRequests.
RemoveRaftVoterResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for RemoveRaftVoterResponses.
RenewDelegationTokenRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for RenewDelegationTokenRequests.
RenewDelegationTokenResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for RenewDelegationTokenResponses.
replicas() - Method in record class io.kroxylicious.proxy.topology.PartitionInfo
Returns the value of the replicas record component.
REQUESTED - Enum constant in enum class io.kroxylicious.proxy.config.tls.TlsClientAuth
 
RequestFilter - Interface in io.kroxylicious.proxy.filter
A Filter that handles all request types, for example to modify the request headers.
RequestFilterResult - Interface in io.kroxylicious.proxy.filter
A specialization of the FilterResult for request filters.
requestFilterResultBuilder() - Method in interface io.kroxylicious.proxy.filter.FilterContext
Creates a builder for a request filter result objects.
RequestFilterResultBuilder - Interface in io.kroxylicious.proxy.filter
Builder for request filter results.
requireConfig(Object, C) - Static method in class io.kroxylicious.proxy.plugin.Plugins
Checks that the given config is not null, throwing PluginConfigurationException if it is.
REQUIRED - Enum constant in enum class io.kroxylicious.proxy.config.tls.TlsClientAuth
 
respondWith(ResponseHeaderData, ApiMessage) - Method in interface io.kroxylicious.proxy.router.RouterContext
Begins building a router response that delivers a synthesised response to the client.
respondWith(ApiMessage) - Method in interface io.kroxylicious.proxy.router.RouterContext
Begins building a router response that delivers the given response body to the client.
respondWithError(RequestHeaderData, ApiMessage, ApiException) - Method in interface io.kroxylicious.proxy.router.RouterContext
Begins building a router result that generates an error response for the client.
respondWithoutReply() - Method in interface io.kroxylicious.proxy.router.RouterContext
Begins building a router result for a fire-and-forget request where no response is delivered to the client (e.g. acks=0 PRODUCE).
Response delivery - Search tag in interface io.kroxylicious.proxy.router.RouterContext
Section
ResponseFilter - Interface in io.kroxylicious.proxy.filter
A Filter that handles all response types.
ResponseFilterResult - Interface in io.kroxylicious.proxy.filter
A specialization of the FilterResult for response filters.
responseFilterResultBuilder() - Method in interface io.kroxylicious.proxy.filter.FilterContext
Creates a builder for a request filter result objects.
ResponseFilterResultBuilder - Interface in io.kroxylicious.proxy.filter
Builder for response filter results.
routeNames() - Method in interface io.kroxylicious.proxy.router.RouterFactoryContext
Returns the names of the routes configured for this router.
Router - Interface in io.kroxylicious.proxy.router
A router decides which route should handle a given incoming Kafka request.
RouterContext - Interface in io.kroxylicious.proxy.router
RouterFactory<C,I> - Interface in io.kroxylicious.proxy.router
A pluggable source of Router instances.
RouterFactoryContext - Interface in io.kroxylicious.proxy.router
Context for RouterFactory initialisation and router creation, providing access to the plugin registry and router identity.
routerName() - Method in interface io.kroxylicious.proxy.router.RouterFactoryContext
Returns the name of this router, as declared in the router definition.
RouterResponse - Interface in io.kroxylicious.proxy.router

S

SaslAuthenticateRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for SaslAuthenticateRequests.
SaslAuthenticateResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for SaslAuthenticateResponses.
SaslHandshakeRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for SaslHandshakeRequests.
SaslHandshakeResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for SaslHandshakeResponses.
SaslSubjectBuilder - Interface in io.kroxylicious.proxy.authentication
Builds a Subject based on information available from a successful SASL authentication.
SaslSubjectBuilder.Context - Interface in io.kroxylicious.proxy.authentication
The context that's passed to SaslSubjectBuilder.buildSaslSubject(Context).
SaslSubjectBuilderService<C> - Interface in io.kroxylicious.proxy.authentication
 
sendRequest(VirtualNode, RequestHeaderData, ApiMessage) - Method in interface io.kroxylicious.proxy.router.RouterContext
Sends a request to a specific broker identified by virtual node.
sendRequest(RequestHeaderData, ApiMessage) - Method in interface io.kroxylicious.proxy.filter.FilterContext
Send a request from a filter towards the broker.
ServerOptions - Record Class in io.kroxylicious.proxy.config.tls
Options that control TLS negotiation when in server mode.
ServerOptions(TlsClientAuth) - Constructor for record class io.kroxylicious.proxy.config.tls.ServerOptions
Creates an instance of a ServerOptions record class.
ServerTlsCredentialSupplier - Interface in io.kroxylicious.proxy.tls
Supplies TLS credentials for proxy-to-server (upstream) TLS connections.
ServerTlsCredentialSupplierContext - Interface in io.kroxylicious.proxy.tls
Runtime context provided to ServerTlsCredentialSupplier instances when TLS credentials are requested.
ServerTlsCredentialSupplierFactory<C,I> - Interface in io.kroxylicious.proxy.tls
A pluggable factory for creating ServerTlsCredentialSupplier instances.
ServerTlsCredentialSupplierFactoryContext - Interface in io.kroxylicious.proxy.tls
Construction context for ServerTlsCredentialSupplier instances.
sessionId() - Method in interface io.kroxylicious.proxy.filter.FilterContext
An id which uniquely identifies the connection with the client in both time and space.
sessionId() - Method in interface io.kroxylicious.proxy.router.RouterContext
Returns the unique identifier for the current proxy session.
ShareAcknowledgeRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ShareAcknowledgeRequests.
ShareAcknowledgeResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ShareAcknowledgeResponses.
ShareFetchRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ShareFetchRequests.
ShareFetchResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ShareFetchResponses.
ShareGroupDescribeRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ShareGroupDescribeRequests.
ShareGroupDescribeResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ShareGroupDescribeResponses.
ShareGroupHeartbeatRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ShareGroupHeartbeatRequests.
ShareGroupHeartbeatResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for ShareGroupHeartbeatResponses.
shortCircuitResponse() - Method in interface io.kroxylicious.proxy.filter.RequestFilterResult
If true, the request is carrying a short circuit response.
shortCircuitResponse(ResponseHeaderData, ApiMessage) - Method in interface io.kroxylicious.proxy.filter.RequestFilterResultBuilder
A short-circuit response towards the client.
shortCircuitResponse(ApiMessage) - Method in interface io.kroxylicious.proxy.filter.RequestFilterResultBuilder
A short-circuit response towards the client.
shouldHandleAddOffsetsToTxnRequest(short) - Method in interface io.kroxylicious.proxy.filter.AddOffsetsToTxnRequestFilter
Determine if a request message of type AddOffsetsToTxnRequest should be handled by this filter implementation.
shouldHandleAddOffsetsToTxnResponse(short) - Method in interface io.kroxylicious.proxy.filter.AddOffsetsToTxnResponseFilter
Determine if a response message of type AddOffsetsToTxnResponse should be handled by this filter implementation.
shouldHandleAddPartitionsToTxnRequest(short) - Method in interface io.kroxylicious.proxy.filter.AddPartitionsToTxnRequestFilter
Determine if a request message of type AddPartitionsToTxnRequest should be handled by this filter implementation.
shouldHandleAddPartitionsToTxnResponse(short) - Method in interface io.kroxylicious.proxy.filter.AddPartitionsToTxnResponseFilter
Determine if a response message of type AddPartitionsToTxnResponse should be handled by this filter implementation.
shouldHandleAddRaftVoterRequest(short) - Method in interface io.kroxylicious.proxy.filter.AddRaftVoterRequestFilter
Determine if a request message of type AddRaftVoterRequest should be handled by this filter implementation.
shouldHandleAddRaftVoterResponse(short) - Method in interface io.kroxylicious.proxy.filter.AddRaftVoterResponseFilter
Determine if a response message of type AddRaftVoterResponse should be handled by this filter implementation.
shouldHandleAllocateProducerIdsRequest(short) - Method in interface io.kroxylicious.proxy.filter.AllocateProducerIdsRequestFilter
Determine if a request message of type AllocateProducerIdsRequest should be handled by this filter implementation.
shouldHandleAllocateProducerIdsResponse(short) - Method in interface io.kroxylicious.proxy.filter.AllocateProducerIdsResponseFilter
Determine if a response message of type AllocateProducerIdsResponse should be handled by this filter implementation.
shouldHandleAlterClientQuotasRequest(short) - Method in interface io.kroxylicious.proxy.filter.AlterClientQuotasRequestFilter
Determine if a request message of type AlterClientQuotasRequest should be handled by this filter implementation.
shouldHandleAlterClientQuotasResponse(short) - Method in interface io.kroxylicious.proxy.filter.AlterClientQuotasResponseFilter
Determine if a response message of type AlterClientQuotasResponse should be handled by this filter implementation.
shouldHandleAlterConfigsRequest(short) - Method in interface io.kroxylicious.proxy.filter.AlterConfigsRequestFilter
Determine if a request message of type AlterConfigsRequest should be handled by this filter implementation.
shouldHandleAlterConfigsResponse(short) - Method in interface io.kroxylicious.proxy.filter.AlterConfigsResponseFilter
Determine if a response message of type AlterConfigsResponse should be handled by this filter implementation.
shouldHandleAlterPartitionReassignmentsRequest(short) - Method in interface io.kroxylicious.proxy.filter.AlterPartitionReassignmentsRequestFilter
Determine if a request message of type AlterPartitionReassignmentsRequest should be handled by this filter implementation.
shouldHandleAlterPartitionReassignmentsResponse(short) - Method in interface io.kroxylicious.proxy.filter.AlterPartitionReassignmentsResponseFilter
Determine if a response message of type AlterPartitionReassignmentsResponse should be handled by this filter implementation.
shouldHandleAlterPartitionRequest(short) - Method in interface io.kroxylicious.proxy.filter.AlterPartitionRequestFilter
Determine if a request message of type AlterPartitionRequest should be handled by this filter implementation.
shouldHandleAlterPartitionResponse(short) - Method in interface io.kroxylicious.proxy.filter.AlterPartitionResponseFilter
Determine if a response message of type AlterPartitionResponse should be handled by this filter implementation.
shouldHandleAlterReplicaLogDirsRequest(short) - Method in interface io.kroxylicious.proxy.filter.AlterReplicaLogDirsRequestFilter
Determine if a request message of type AlterReplicaLogDirsRequest should be handled by this filter implementation.
shouldHandleAlterReplicaLogDirsResponse(short) - Method in interface io.kroxylicious.proxy.filter.AlterReplicaLogDirsResponseFilter
Determine if a response message of type AlterReplicaLogDirsResponse should be handled by this filter implementation.
shouldHandleAlterShareGroupOffsetsRequest(short) - Method in interface io.kroxylicious.proxy.filter.AlterShareGroupOffsetsRequestFilter
Determine if a request message of type AlterShareGroupOffsetsRequest should be handled by this filter implementation.
shouldHandleAlterShareGroupOffsetsResponse(short) - Method in interface io.kroxylicious.proxy.filter.AlterShareGroupOffsetsResponseFilter
Determine if a response message of type AlterShareGroupOffsetsResponse should be handled by this filter implementation.
shouldHandleAlterUserScramCredentialsRequest(short) - Method in interface io.kroxylicious.proxy.filter.AlterUserScramCredentialsRequestFilter
Determine if a request message of type AlterUserScramCredentialsRequest should be handled by this filter implementation.
shouldHandleAlterUserScramCredentialsResponse(short) - Method in interface io.kroxylicious.proxy.filter.AlterUserScramCredentialsResponseFilter
Determine if a response message of type AlterUserScramCredentialsResponse should be handled by this filter implementation.
shouldHandleApiVersionsRequest(short) - Method in interface io.kroxylicious.proxy.filter.ApiVersionsRequestFilter
Determine if a request message of type ApiVersionsRequest should be handled by this filter implementation.
shouldHandleApiVersionsResponse(short) - Method in interface io.kroxylicious.proxy.filter.ApiVersionsResponseFilter
Determine if a response message of type ApiVersionsResponse should be handled by this filter implementation.
shouldHandleAssignReplicasToDirsRequest(short) - Method in interface io.kroxylicious.proxy.filter.AssignReplicasToDirsRequestFilter
Determine if a request message of type AssignReplicasToDirsRequest should be handled by this filter implementation.
shouldHandleAssignReplicasToDirsResponse(short) - Method in interface io.kroxylicious.proxy.filter.AssignReplicasToDirsResponseFilter
Determine if a response message of type AssignReplicasToDirsResponse should be handled by this filter implementation.
shouldHandleBeginQuorumEpochRequest(short) - Method in interface io.kroxylicious.proxy.filter.BeginQuorumEpochRequestFilter
Determine if a request message of type BeginQuorumEpochRequest should be handled by this filter implementation.
shouldHandleBeginQuorumEpochResponse(short) - Method in interface io.kroxylicious.proxy.filter.BeginQuorumEpochResponseFilter
Determine if a response message of type BeginQuorumEpochResponse should be handled by this filter implementation.
shouldHandleBrokerHeartbeatRequest(short) - Method in interface io.kroxylicious.proxy.filter.BrokerHeartbeatRequestFilter
Determine if a request message of type BrokerHeartbeatRequest should be handled by this filter implementation.
shouldHandleBrokerHeartbeatResponse(short) - Method in interface io.kroxylicious.proxy.filter.BrokerHeartbeatResponseFilter
Determine if a response message of type BrokerHeartbeatResponse should be handled by this filter implementation.
shouldHandleBrokerRegistrationRequest(short) - Method in interface io.kroxylicious.proxy.filter.BrokerRegistrationRequestFilter
Determine if a request message of type BrokerRegistrationRequest should be handled by this filter implementation.
shouldHandleBrokerRegistrationResponse(short) - Method in interface io.kroxylicious.proxy.filter.BrokerRegistrationResponseFilter
Determine if a response message of type BrokerRegistrationResponse should be handled by this filter implementation.
shouldHandleConsumerGroupDescribeRequest(short) - Method in interface io.kroxylicious.proxy.filter.ConsumerGroupDescribeRequestFilter
Determine if a request message of type ConsumerGroupDescribeRequest should be handled by this filter implementation.
shouldHandleConsumerGroupDescribeResponse(short) - Method in interface io.kroxylicious.proxy.filter.ConsumerGroupDescribeResponseFilter
Determine if a response message of type ConsumerGroupDescribeResponse should be handled by this filter implementation.
shouldHandleConsumerGroupHeartbeatRequest(short) - Method in interface io.kroxylicious.proxy.filter.ConsumerGroupHeartbeatRequestFilter
Determine if a request message of type ConsumerGroupHeartbeatRequest should be handled by this filter implementation.
shouldHandleConsumerGroupHeartbeatResponse(short) - Method in interface io.kroxylicious.proxy.filter.ConsumerGroupHeartbeatResponseFilter
Determine if a response message of type ConsumerGroupHeartbeatResponse should be handled by this filter implementation.
shouldHandleControllerRegistrationRequest(short) - Method in interface io.kroxylicious.proxy.filter.ControllerRegistrationRequestFilter
Determine if a request message of type ControllerRegistrationRequest should be handled by this filter implementation.
shouldHandleControllerRegistrationResponse(short) - Method in interface io.kroxylicious.proxy.filter.ControllerRegistrationResponseFilter
Determine if a response message of type ControllerRegistrationResponse should be handled by this filter implementation.
shouldHandleCreateAclsRequest(short) - Method in interface io.kroxylicious.proxy.filter.CreateAclsRequestFilter
Determine if a request message of type CreateAclsRequest should be handled by this filter implementation.
shouldHandleCreateAclsResponse(short) - Method in interface io.kroxylicious.proxy.filter.CreateAclsResponseFilter
Determine if a response message of type CreateAclsResponse should be handled by this filter implementation.
shouldHandleCreateDelegationTokenRequest(short) - Method in interface io.kroxylicious.proxy.filter.CreateDelegationTokenRequestFilter
Determine if a request message of type CreateDelegationTokenRequest should be handled by this filter implementation.
shouldHandleCreateDelegationTokenResponse(short) - Method in interface io.kroxylicious.proxy.filter.CreateDelegationTokenResponseFilter
Determine if a response message of type CreateDelegationTokenResponse should be handled by this filter implementation.
shouldHandleCreatePartitionsRequest(short) - Method in interface io.kroxylicious.proxy.filter.CreatePartitionsRequestFilter
Determine if a request message of type CreatePartitionsRequest should be handled by this filter implementation.
shouldHandleCreatePartitionsResponse(short) - Method in interface io.kroxylicious.proxy.filter.CreatePartitionsResponseFilter
Determine if a response message of type CreatePartitionsResponse should be handled by this filter implementation.
shouldHandleCreateTopicsRequest(short) - Method in interface io.kroxylicious.proxy.filter.CreateTopicsRequestFilter
Determine if a request message of type CreateTopicsRequest should be handled by this filter implementation.
shouldHandleCreateTopicsResponse(short) - Method in interface io.kroxylicious.proxy.filter.CreateTopicsResponseFilter
Determine if a response message of type CreateTopicsResponse should be handled by this filter implementation.
shouldHandleDeleteAclsRequest(short) - Method in interface io.kroxylicious.proxy.filter.DeleteAclsRequestFilter
Determine if a request message of type DeleteAclsRequest should be handled by this filter implementation.
shouldHandleDeleteAclsResponse(short) - Method in interface io.kroxylicious.proxy.filter.DeleteAclsResponseFilter
Determine if a response message of type DeleteAclsResponse should be handled by this filter implementation.
shouldHandleDeleteGroupsRequest(short) - Method in interface io.kroxylicious.proxy.filter.DeleteGroupsRequestFilter
Determine if a request message of type DeleteGroupsRequest should be handled by this filter implementation.
shouldHandleDeleteGroupsResponse(short) - Method in interface io.kroxylicious.proxy.filter.DeleteGroupsResponseFilter
Determine if a response message of type DeleteGroupsResponse should be handled by this filter implementation.
shouldHandleDeleteRecordsRequest(short) - Method in interface io.kroxylicious.proxy.filter.DeleteRecordsRequestFilter
Determine if a request message of type DeleteRecordsRequest should be handled by this filter implementation.
shouldHandleDeleteRecordsResponse(short) - Method in interface io.kroxylicious.proxy.filter.DeleteRecordsResponseFilter
Determine if a response message of type DeleteRecordsResponse should be handled by this filter implementation.
shouldHandleDeleteShareGroupOffsetsRequest(short) - Method in interface io.kroxylicious.proxy.filter.DeleteShareGroupOffsetsRequestFilter
Determine if a request message of type DeleteShareGroupOffsetsRequest should be handled by this filter implementation.
shouldHandleDeleteShareGroupOffsetsResponse(short) - Method in interface io.kroxylicious.proxy.filter.DeleteShareGroupOffsetsResponseFilter
Determine if a response message of type DeleteShareGroupOffsetsResponse should be handled by this filter implementation.
shouldHandleDeleteShareGroupStateRequest(short) - Method in interface io.kroxylicious.proxy.filter.DeleteShareGroupStateRequestFilter
Determine if a request message of type DeleteShareGroupStateRequest should be handled by this filter implementation.
shouldHandleDeleteShareGroupStateResponse(short) - Method in interface io.kroxylicious.proxy.filter.DeleteShareGroupStateResponseFilter
Determine if a response message of type DeleteShareGroupStateResponse should be handled by this filter implementation.
shouldHandleDeleteTopicsRequest(short) - Method in interface io.kroxylicious.proxy.filter.DeleteTopicsRequestFilter
Determine if a request message of type DeleteTopicsRequest should be handled by this filter implementation.
shouldHandleDeleteTopicsResponse(short) - Method in interface io.kroxylicious.proxy.filter.DeleteTopicsResponseFilter
Determine if a response message of type DeleteTopicsResponse should be handled by this filter implementation.
shouldHandleDescribeAclsRequest(short) - Method in interface io.kroxylicious.proxy.filter.DescribeAclsRequestFilter
Determine if a request message of type DescribeAclsRequest should be handled by this filter implementation.
shouldHandleDescribeAclsResponse(short) - Method in interface io.kroxylicious.proxy.filter.DescribeAclsResponseFilter
Determine if a response message of type DescribeAclsResponse should be handled by this filter implementation.
shouldHandleDescribeClientQuotasRequest(short) - Method in interface io.kroxylicious.proxy.filter.DescribeClientQuotasRequestFilter
Determine if a request message of type DescribeClientQuotasRequest should be handled by this filter implementation.
shouldHandleDescribeClientQuotasResponse(short) - Method in interface io.kroxylicious.proxy.filter.DescribeClientQuotasResponseFilter
Determine if a response message of type DescribeClientQuotasResponse should be handled by this filter implementation.
shouldHandleDescribeClusterRequest(short) - Method in interface io.kroxylicious.proxy.filter.DescribeClusterRequestFilter
Determine if a request message of type DescribeClusterRequest should be handled by this filter implementation.
shouldHandleDescribeClusterResponse(short) - Method in interface io.kroxylicious.proxy.filter.DescribeClusterResponseFilter
Determine if a response message of type DescribeClusterResponse should be handled by this filter implementation.
shouldHandleDescribeConfigsRequest(short) - Method in interface io.kroxylicious.proxy.filter.DescribeConfigsRequestFilter
Determine if a request message of type DescribeConfigsRequest should be handled by this filter implementation.
shouldHandleDescribeConfigsResponse(short) - Method in interface io.kroxylicious.proxy.filter.DescribeConfigsResponseFilter
Determine if a response message of type DescribeConfigsResponse should be handled by this filter implementation.
shouldHandleDescribeDelegationTokenRequest(short) - Method in interface io.kroxylicious.proxy.filter.DescribeDelegationTokenRequestFilter
Determine if a request message of type DescribeDelegationTokenRequest should be handled by this filter implementation.
shouldHandleDescribeDelegationTokenResponse(short) - Method in interface io.kroxylicious.proxy.filter.DescribeDelegationTokenResponseFilter
Determine if a response message of type DescribeDelegationTokenResponse should be handled by this filter implementation.
shouldHandleDescribeGroupsRequest(short) - Method in interface io.kroxylicious.proxy.filter.DescribeGroupsRequestFilter
Determine if a request message of type DescribeGroupsRequest should be handled by this filter implementation.
shouldHandleDescribeGroupsResponse(short) - Method in interface io.kroxylicious.proxy.filter.DescribeGroupsResponseFilter
Determine if a response message of type DescribeGroupsResponse should be handled by this filter implementation.
shouldHandleDescribeLogDirsRequest(short) - Method in interface io.kroxylicious.proxy.filter.DescribeLogDirsRequestFilter
Determine if a request message of type DescribeLogDirsRequest should be handled by this filter implementation.
shouldHandleDescribeLogDirsResponse(short) - Method in interface io.kroxylicious.proxy.filter.DescribeLogDirsResponseFilter
Determine if a response message of type DescribeLogDirsResponse should be handled by this filter implementation.
shouldHandleDescribeProducersRequest(short) - Method in interface io.kroxylicious.proxy.filter.DescribeProducersRequestFilter
Determine if a request message of type DescribeProducersRequest should be handled by this filter implementation.
shouldHandleDescribeProducersResponse(short) - Method in interface io.kroxylicious.proxy.filter.DescribeProducersResponseFilter
Determine if a response message of type DescribeProducersResponse should be handled by this filter implementation.
shouldHandleDescribeQuorumRequest(short) - Method in interface io.kroxylicious.proxy.filter.DescribeQuorumRequestFilter
Determine if a request message of type DescribeQuorumRequest should be handled by this filter implementation.
shouldHandleDescribeQuorumResponse(short) - Method in interface io.kroxylicious.proxy.filter.DescribeQuorumResponseFilter
Determine if a response message of type DescribeQuorumResponse should be handled by this filter implementation.
shouldHandleDescribeShareGroupOffsetsRequest(short) - Method in interface io.kroxylicious.proxy.filter.DescribeShareGroupOffsetsRequestFilter
Determine if a request message of type DescribeShareGroupOffsetsRequest should be handled by this filter implementation.
shouldHandleDescribeShareGroupOffsetsResponse(short) - Method in interface io.kroxylicious.proxy.filter.DescribeShareGroupOffsetsResponseFilter
Determine if a response message of type DescribeShareGroupOffsetsResponse should be handled by this filter implementation.
shouldHandleDescribeTopicPartitionsRequest(short) - Method in interface io.kroxylicious.proxy.filter.DescribeTopicPartitionsRequestFilter
Determine if a request message of type DescribeTopicPartitionsRequest should be handled by this filter implementation.
shouldHandleDescribeTopicPartitionsResponse(short) - Method in interface io.kroxylicious.proxy.filter.DescribeTopicPartitionsResponseFilter
Determine if a response message of type DescribeTopicPartitionsResponse should be handled by this filter implementation.
shouldHandleDescribeTransactionsRequest(short) - Method in interface io.kroxylicious.proxy.filter.DescribeTransactionsRequestFilter
Determine if a request message of type DescribeTransactionsRequest should be handled by this filter implementation.
shouldHandleDescribeTransactionsResponse(short) - Method in interface io.kroxylicious.proxy.filter.DescribeTransactionsResponseFilter
Determine if a response message of type DescribeTransactionsResponse should be handled by this filter implementation.
shouldHandleDescribeUserScramCredentialsRequest(short) - Method in interface io.kroxylicious.proxy.filter.DescribeUserScramCredentialsRequestFilter
Determine if a request message of type DescribeUserScramCredentialsRequest should be handled by this filter implementation.
shouldHandleDescribeUserScramCredentialsResponse(short) - Method in interface io.kroxylicious.proxy.filter.DescribeUserScramCredentialsResponseFilter
Determine if a response message of type DescribeUserScramCredentialsResponse should be handled by this filter implementation.
shouldHandleElectLeadersRequest(short) - Method in interface io.kroxylicious.proxy.filter.ElectLeadersRequestFilter
Determine if a request message of type ElectLeadersRequest should be handled by this filter implementation.
shouldHandleElectLeadersResponse(short) - Method in interface io.kroxylicious.proxy.filter.ElectLeadersResponseFilter
Determine if a response message of type ElectLeadersResponse should be handled by this filter implementation.
shouldHandleEndQuorumEpochRequest(short) - Method in interface io.kroxylicious.proxy.filter.EndQuorumEpochRequestFilter
Determine if a request message of type EndQuorumEpochRequest should be handled by this filter implementation.
shouldHandleEndQuorumEpochResponse(short) - Method in interface io.kroxylicious.proxy.filter.EndQuorumEpochResponseFilter
Determine if a response message of type EndQuorumEpochResponse should be handled by this filter implementation.
shouldHandleEndTxnRequest(short) - Method in interface io.kroxylicious.proxy.filter.EndTxnRequestFilter
Determine if a request message of type EndTxnRequest should be handled by this filter implementation.
shouldHandleEndTxnResponse(short) - Method in interface io.kroxylicious.proxy.filter.EndTxnResponseFilter
Determine if a response message of type EndTxnResponse should be handled by this filter implementation.
shouldHandleEnvelopeRequest(short) - Method in interface io.kroxylicious.proxy.filter.EnvelopeRequestFilter
Determine if a request message of type EnvelopeRequest should be handled by this filter implementation.
shouldHandleEnvelopeResponse(short) - Method in interface io.kroxylicious.proxy.filter.EnvelopeResponseFilter
Determine if a response message of type EnvelopeResponse should be handled by this filter implementation.
shouldHandleExpireDelegationTokenRequest(short) - Method in interface io.kroxylicious.proxy.filter.ExpireDelegationTokenRequestFilter
Determine if a request message of type ExpireDelegationTokenRequest should be handled by this filter implementation.
shouldHandleExpireDelegationTokenResponse(short) - Method in interface io.kroxylicious.proxy.filter.ExpireDelegationTokenResponseFilter
Determine if a response message of type ExpireDelegationTokenResponse should be handled by this filter implementation.
shouldHandleFetchRequest(short) - Method in interface io.kroxylicious.proxy.filter.FetchRequestFilter
Determine if a request message of type FetchRequest should be handled by this filter implementation.
shouldHandleFetchResponse(short) - Method in interface io.kroxylicious.proxy.filter.FetchResponseFilter
Determine if a response message of type FetchResponse should be handled by this filter implementation.
shouldHandleFetchSnapshotRequest(short) - Method in interface io.kroxylicious.proxy.filter.FetchSnapshotRequestFilter
Determine if a request message of type FetchSnapshotRequest should be handled by this filter implementation.
shouldHandleFetchSnapshotResponse(short) - Method in interface io.kroxylicious.proxy.filter.FetchSnapshotResponseFilter
Determine if a response message of type FetchSnapshotResponse should be handled by this filter implementation.
shouldHandleFindCoordinatorRequest(short) - Method in interface io.kroxylicious.proxy.filter.FindCoordinatorRequestFilter
Determine if a request message of type FindCoordinatorRequest should be handled by this filter implementation.
shouldHandleFindCoordinatorResponse(short) - Method in interface io.kroxylicious.proxy.filter.FindCoordinatorResponseFilter
Determine if a response message of type FindCoordinatorResponse should be handled by this filter implementation.
shouldHandleGetTelemetrySubscriptionsRequest(short) - Method in interface io.kroxylicious.proxy.filter.GetTelemetrySubscriptionsRequestFilter
Determine if a request message of type GetTelemetrySubscriptionsRequest should be handled by this filter implementation.
shouldHandleGetTelemetrySubscriptionsResponse(short) - Method in interface io.kroxylicious.proxy.filter.GetTelemetrySubscriptionsResponseFilter
Determine if a response message of type GetTelemetrySubscriptionsResponse should be handled by this filter implementation.
shouldHandleHeartbeatRequest(short) - Method in interface io.kroxylicious.proxy.filter.HeartbeatRequestFilter
Determine if a request message of type HeartbeatRequest should be handled by this filter implementation.
shouldHandleHeartbeatResponse(short) - Method in interface io.kroxylicious.proxy.filter.HeartbeatResponseFilter
Determine if a response message of type HeartbeatResponse should be handled by this filter implementation.
shouldHandleIncrementalAlterConfigsRequest(short) - Method in interface io.kroxylicious.proxy.filter.IncrementalAlterConfigsRequestFilter
Determine if a request message of type IncrementalAlterConfigsRequest should be handled by this filter implementation.
shouldHandleIncrementalAlterConfigsResponse(short) - Method in interface io.kroxylicious.proxy.filter.IncrementalAlterConfigsResponseFilter
Determine if a response message of type IncrementalAlterConfigsResponse should be handled by this filter implementation.
shouldHandleInitializeShareGroupStateRequest(short) - Method in interface io.kroxylicious.proxy.filter.InitializeShareGroupStateRequestFilter
Determine if a request message of type InitializeShareGroupStateRequest should be handled by this filter implementation.
shouldHandleInitializeShareGroupStateResponse(short) - Method in interface io.kroxylicious.proxy.filter.InitializeShareGroupStateResponseFilter
Determine if a response message of type InitializeShareGroupStateResponse should be handled by this filter implementation.
shouldHandleInitProducerIdRequest(short) - Method in interface io.kroxylicious.proxy.filter.InitProducerIdRequestFilter
Determine if a request message of type InitProducerIdRequest should be handled by this filter implementation.
shouldHandleInitProducerIdResponse(short) - Method in interface io.kroxylicious.proxy.filter.InitProducerIdResponseFilter
Determine if a response message of type InitProducerIdResponse should be handled by this filter implementation.
shouldHandleJoinGroupRequest(short) - Method in interface io.kroxylicious.proxy.filter.JoinGroupRequestFilter
Determine if a request message of type JoinGroupRequest should be handled by this filter implementation.
shouldHandleJoinGroupResponse(short) - Method in interface io.kroxylicious.proxy.filter.JoinGroupResponseFilter
Determine if a response message of type JoinGroupResponse should be handled by this filter implementation.
shouldHandleLeaveGroupRequest(short) - Method in interface io.kroxylicious.proxy.filter.LeaveGroupRequestFilter
Determine if a request message of type LeaveGroupRequest should be handled by this filter implementation.
shouldHandleLeaveGroupResponse(short) - Method in interface io.kroxylicious.proxy.filter.LeaveGroupResponseFilter
Determine if a response message of type LeaveGroupResponse should be handled by this filter implementation.
shouldHandleListConfigResourcesRequest(short) - Method in interface io.kroxylicious.proxy.filter.ListConfigResourcesRequestFilter
Determine if a request message of type ListConfigResourcesRequest should be handled by this filter implementation.
shouldHandleListConfigResourcesResponse(short) - Method in interface io.kroxylicious.proxy.filter.ListConfigResourcesResponseFilter
Determine if a response message of type ListConfigResourcesResponse should be handled by this filter implementation.
shouldHandleListGroupsRequest(short) - Method in interface io.kroxylicious.proxy.filter.ListGroupsRequestFilter
Determine if a request message of type ListGroupsRequest should be handled by this filter implementation.
shouldHandleListGroupsResponse(short) - Method in interface io.kroxylicious.proxy.filter.ListGroupsResponseFilter
Determine if a response message of type ListGroupsResponse should be handled by this filter implementation.
shouldHandleListOffsetsRequest(short) - Method in interface io.kroxylicious.proxy.filter.ListOffsetsRequestFilter
Determine if a request message of type ListOffsetsRequest should be handled by this filter implementation.
shouldHandleListOffsetsResponse(short) - Method in interface io.kroxylicious.proxy.filter.ListOffsetsResponseFilter
Determine if a response message of type ListOffsetsResponse should be handled by this filter implementation.
shouldHandleListPartitionReassignmentsRequest(short) - Method in interface io.kroxylicious.proxy.filter.ListPartitionReassignmentsRequestFilter
Determine if a request message of type ListPartitionReassignmentsRequest should be handled by this filter implementation.
shouldHandleListPartitionReassignmentsResponse(short) - Method in interface io.kroxylicious.proxy.filter.ListPartitionReassignmentsResponseFilter
Determine if a response message of type ListPartitionReassignmentsResponse should be handled by this filter implementation.
shouldHandleListTransactionsRequest(short) - Method in interface io.kroxylicious.proxy.filter.ListTransactionsRequestFilter
Determine if a request message of type ListTransactionsRequest should be handled by this filter implementation.
shouldHandleListTransactionsResponse(short) - Method in interface io.kroxylicious.proxy.filter.ListTransactionsResponseFilter
Determine if a response message of type ListTransactionsResponse should be handled by this filter implementation.
shouldHandleMetadataRequest(short) - Method in interface io.kroxylicious.proxy.filter.MetadataRequestFilter
Determine if a request message of type MetadataRequest should be handled by this filter implementation.
shouldHandleMetadataResponse(short) - Method in interface io.kroxylicious.proxy.filter.MetadataResponseFilter
Determine if a response message of type MetadataResponse should be handled by this filter implementation.
shouldHandleOffsetCommitRequest(short) - Method in interface io.kroxylicious.proxy.filter.OffsetCommitRequestFilter
Determine if a request message of type OffsetCommitRequest should be handled by this filter implementation.
shouldHandleOffsetCommitResponse(short) - Method in interface io.kroxylicious.proxy.filter.OffsetCommitResponseFilter
Determine if a response message of type OffsetCommitResponse should be handled by this filter implementation.
shouldHandleOffsetDeleteRequest(short) - Method in interface io.kroxylicious.proxy.filter.OffsetDeleteRequestFilter
Determine if a request message of type OffsetDeleteRequest should be handled by this filter implementation.
shouldHandleOffsetDeleteResponse(short) - Method in interface io.kroxylicious.proxy.filter.OffsetDeleteResponseFilter
Determine if a response message of type OffsetDeleteResponse should be handled by this filter implementation.
shouldHandleOffsetFetchRequest(short) - Method in interface io.kroxylicious.proxy.filter.OffsetFetchRequestFilter
Determine if a request message of type OffsetFetchRequest should be handled by this filter implementation.
shouldHandleOffsetFetchResponse(short) - Method in interface io.kroxylicious.proxy.filter.OffsetFetchResponseFilter
Determine if a response message of type OffsetFetchResponse should be handled by this filter implementation.
shouldHandleOffsetForLeaderEpochRequest(short) - Method in interface io.kroxylicious.proxy.filter.OffsetForLeaderEpochRequestFilter
Determine if a request message of type OffsetForLeaderEpochRequest should be handled by this filter implementation.
shouldHandleOffsetForLeaderEpochResponse(short) - Method in interface io.kroxylicious.proxy.filter.OffsetForLeaderEpochResponseFilter
Determine if a response message of type OffsetForLeaderEpochResponse should be handled by this filter implementation.
shouldHandleProduceRequest(short) - Method in interface io.kroxylicious.proxy.filter.ProduceRequestFilter
Determine if a request message of type ProduceRequest should be handled by this filter implementation.
shouldHandleProduceResponse(short) - Method in interface io.kroxylicious.proxy.filter.ProduceResponseFilter
Determine if a response message of type ProduceResponse should be handled by this filter implementation.
shouldHandlePushTelemetryRequest(short) - Method in interface io.kroxylicious.proxy.filter.PushTelemetryRequestFilter
Determine if a request message of type PushTelemetryRequest should be handled by this filter implementation.
shouldHandlePushTelemetryResponse(short) - Method in interface io.kroxylicious.proxy.filter.PushTelemetryResponseFilter
Determine if a response message of type PushTelemetryResponse should be handled by this filter implementation.
shouldHandleReadShareGroupStateRequest(short) - Method in interface io.kroxylicious.proxy.filter.ReadShareGroupStateRequestFilter
Determine if a request message of type ReadShareGroupStateRequest should be handled by this filter implementation.
shouldHandleReadShareGroupStateResponse(short) - Method in interface io.kroxylicious.proxy.filter.ReadShareGroupStateResponseFilter
Determine if a response message of type ReadShareGroupStateResponse should be handled by this filter implementation.
shouldHandleReadShareGroupStateSummaryRequest(short) - Method in interface io.kroxylicious.proxy.filter.ReadShareGroupStateSummaryRequestFilter
Determine if a request message of type ReadShareGroupStateSummaryRequest should be handled by this filter implementation.
shouldHandleReadShareGroupStateSummaryResponse(short) - Method in interface io.kroxylicious.proxy.filter.ReadShareGroupStateSummaryResponseFilter
Determine if a response message of type ReadShareGroupStateSummaryResponse should be handled by this filter implementation.
shouldHandleRemoveRaftVoterRequest(short) - Method in interface io.kroxylicious.proxy.filter.RemoveRaftVoterRequestFilter
Determine if a request message of type RemoveRaftVoterRequest should be handled by this filter implementation.
shouldHandleRemoveRaftVoterResponse(short) - Method in interface io.kroxylicious.proxy.filter.RemoveRaftVoterResponseFilter
Determine if a response message of type RemoveRaftVoterResponse should be handled by this filter implementation.
shouldHandleRenewDelegationTokenRequest(short) - Method in interface io.kroxylicious.proxy.filter.RenewDelegationTokenRequestFilter
Determine if a request message of type RenewDelegationTokenRequest should be handled by this filter implementation.
shouldHandleRenewDelegationTokenResponse(short) - Method in interface io.kroxylicious.proxy.filter.RenewDelegationTokenResponseFilter
Determine if a response message of type RenewDelegationTokenResponse should be handled by this filter implementation.
shouldHandleRequest(ApiKeys, short) - Method in interface io.kroxylicious.proxy.filter.RequestFilter
Does this filter implementation want to handle a request.
shouldHandleResponse(ApiKeys, short) - Method in interface io.kroxylicious.proxy.filter.ResponseFilter
Does this filter implementation want to handle a response.
shouldHandleSaslAuthenticateRequest(short) - Method in interface io.kroxylicious.proxy.filter.SaslAuthenticateRequestFilter
Determine if a request message of type SaslAuthenticateRequest should be handled by this filter implementation.
shouldHandleSaslAuthenticateResponse(short) - Method in interface io.kroxylicious.proxy.filter.SaslAuthenticateResponseFilter
Determine if a response message of type SaslAuthenticateResponse should be handled by this filter implementation.
shouldHandleSaslHandshakeRequest(short) - Method in interface io.kroxylicious.proxy.filter.SaslHandshakeRequestFilter
Determine if a request message of type SaslHandshakeRequest should be handled by this filter implementation.
shouldHandleSaslHandshakeResponse(short) - Method in interface io.kroxylicious.proxy.filter.SaslHandshakeResponseFilter
Determine if a response message of type SaslHandshakeResponse should be handled by this filter implementation.
shouldHandleShareAcknowledgeRequest(short) - Method in interface io.kroxylicious.proxy.filter.ShareAcknowledgeRequestFilter
Determine if a request message of type ShareAcknowledgeRequest should be handled by this filter implementation.
shouldHandleShareAcknowledgeResponse(short) - Method in interface io.kroxylicious.proxy.filter.ShareAcknowledgeResponseFilter
Determine if a response message of type ShareAcknowledgeResponse should be handled by this filter implementation.
shouldHandleShareFetchRequest(short) - Method in interface io.kroxylicious.proxy.filter.ShareFetchRequestFilter
Determine if a request message of type ShareFetchRequest should be handled by this filter implementation.
shouldHandleShareFetchResponse(short) - Method in interface io.kroxylicious.proxy.filter.ShareFetchResponseFilter
Determine if a response message of type ShareFetchResponse should be handled by this filter implementation.
shouldHandleShareGroupDescribeRequest(short) - Method in interface io.kroxylicious.proxy.filter.ShareGroupDescribeRequestFilter
Determine if a request message of type ShareGroupDescribeRequest should be handled by this filter implementation.
shouldHandleShareGroupDescribeResponse(short) - Method in interface io.kroxylicious.proxy.filter.ShareGroupDescribeResponseFilter
Determine if a response message of type ShareGroupDescribeResponse should be handled by this filter implementation.
shouldHandleShareGroupHeartbeatRequest(short) - Method in interface io.kroxylicious.proxy.filter.ShareGroupHeartbeatRequestFilter
Determine if a request message of type ShareGroupHeartbeatRequest should be handled by this filter implementation.
shouldHandleShareGroupHeartbeatResponse(short) - Method in interface io.kroxylicious.proxy.filter.ShareGroupHeartbeatResponseFilter
Determine if a response message of type ShareGroupHeartbeatResponse should be handled by this filter implementation.
shouldHandleStreamsGroupDescribeRequest(short) - Method in interface io.kroxylicious.proxy.filter.StreamsGroupDescribeRequestFilter
Determine if a request message of type StreamsGroupDescribeRequest should be handled by this filter implementation.
shouldHandleStreamsGroupDescribeResponse(short) - Method in interface io.kroxylicious.proxy.filter.StreamsGroupDescribeResponseFilter
Determine if a response message of type StreamsGroupDescribeResponse should be handled by this filter implementation.
shouldHandleStreamsGroupHeartbeatRequest(short) - Method in interface io.kroxylicious.proxy.filter.StreamsGroupHeartbeatRequestFilter
Determine if a request message of type StreamsGroupHeartbeatRequest should be handled by this filter implementation.
shouldHandleStreamsGroupHeartbeatResponse(short) - Method in interface io.kroxylicious.proxy.filter.StreamsGroupHeartbeatResponseFilter
Determine if a response message of type StreamsGroupHeartbeatResponse should be handled by this filter implementation.
shouldHandleSyncGroupRequest(short) - Method in interface io.kroxylicious.proxy.filter.SyncGroupRequestFilter
Determine if a request message of type SyncGroupRequest should be handled by this filter implementation.
shouldHandleSyncGroupResponse(short) - Method in interface io.kroxylicious.proxy.filter.SyncGroupResponseFilter
Determine if a response message of type SyncGroupResponse should be handled by this filter implementation.
shouldHandleTxnOffsetCommitRequest(short) - Method in interface io.kroxylicious.proxy.filter.TxnOffsetCommitRequestFilter
Determine if a request message of type TxnOffsetCommitRequest should be handled by this filter implementation.
shouldHandleTxnOffsetCommitResponse(short) - Method in interface io.kroxylicious.proxy.filter.TxnOffsetCommitResponseFilter
Determine if a response message of type TxnOffsetCommitResponse should be handled by this filter implementation.
shouldHandleUnregisterBrokerRequest(short) - Method in interface io.kroxylicious.proxy.filter.UnregisterBrokerRequestFilter
Determine if a request message of type UnregisterBrokerRequest should be handled by this filter implementation.
shouldHandleUnregisterBrokerResponse(short) - Method in interface io.kroxylicious.proxy.filter.UnregisterBrokerResponseFilter
Determine if a response message of type UnregisterBrokerResponse should be handled by this filter implementation.
shouldHandleUpdateFeaturesRequest(short) - Method in interface io.kroxylicious.proxy.filter.UpdateFeaturesRequestFilter
Determine if a request message of type UpdateFeaturesRequest should be handled by this filter implementation.
shouldHandleUpdateFeaturesResponse(short) - Method in interface io.kroxylicious.proxy.filter.UpdateFeaturesResponseFilter
Determine if a response message of type UpdateFeaturesResponse should be handled by this filter implementation.
shouldHandleUpdateRaftVoterRequest(short) - Method in interface io.kroxylicious.proxy.filter.UpdateRaftVoterRequestFilter
Determine if a request message of type UpdateRaftVoterRequest should be handled by this filter implementation.
shouldHandleUpdateRaftVoterResponse(short) - Method in interface io.kroxylicious.proxy.filter.UpdateRaftVoterResponseFilter
Determine if a response message of type UpdateRaftVoterResponse should be handled by this filter implementation.
shouldHandleVoteRequest(short) - Method in interface io.kroxylicious.proxy.filter.VoteRequestFilter
Determine if a request message of type VoteRequest should be handled by this filter implementation.
shouldHandleVoteResponse(short) - Method in interface io.kroxylicious.proxy.filter.VoteResponseFilter
Determine if a response message of type VoteResponse should be handled by this filter implementation.
shouldHandleWriteShareGroupStateRequest(short) - Method in interface io.kroxylicious.proxy.filter.WriteShareGroupStateRequestFilter
Determine if a request message of type WriteShareGroupStateRequest should be handled by this filter implementation.
shouldHandleWriteShareGroupStateResponse(short) - Method in interface io.kroxylicious.proxy.filter.WriteShareGroupStateResponseFilter
Determine if a response message of type WriteShareGroupStateResponse should be handled by this filter implementation.
shouldHandleWriteTxnMarkersRequest(short) - Method in interface io.kroxylicious.proxy.filter.WriteTxnMarkersRequestFilter
Determine if a request message of type WriteTxnMarkersRequest should be handled by this filter implementation.
shouldHandleWriteTxnMarkersResponse(short) - Method in interface io.kroxylicious.proxy.filter.WriteTxnMarkersResponseFilter
Determine if a response message of type WriteTxnMarkersResponse should be handled by this filter implementation.
since() - Element in annotation interface io.kroxylicious.proxy.plugin.DeprecatedPluginName
Returns the version in which the name became deprecated.
sniHostname() - Method in interface io.kroxylicious.proxy.filter.FilterContext
The SNI hostname provided by the client, if any.
staticRoutes() - Method in interface io.kroxylicious.proxy.router.Router
Declares API keys that are always forwarded to a fixed named route without deserialisation.
storeFile() - Method in record class io.kroxylicious.proxy.config.tls.KeyStore
Returns the value of the storeFile record component.
storeFile() - Method in record class io.kroxylicious.proxy.config.tls.TrustStore
Returns the value of the storeFile record component.
storePasswordProvider() - Method in record class io.kroxylicious.proxy.config.tls.KeyStore
Returns the value of the storePasswordProvider record component.
storePasswordProvider() - Method in record class io.kroxylicious.proxy.config.tls.TrustStore
Returns the value of the storePasswordProvider record component.
storeType() - Method in record class io.kroxylicious.proxy.config.tls.KeyStore
Returns the value of the storeType record component.
storeType() - Method in record class io.kroxylicious.proxy.config.tls.TrustStore
Returns the value of the storeType record component.
StreamsGroupDescribeRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for StreamsGroupDescribeRequests.
StreamsGroupDescribeResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for StreamsGroupDescribeResponses.
StreamsGroupHeartbeatRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for StreamsGroupHeartbeatRequests.
StreamsGroupHeartbeatResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for StreamsGroupHeartbeatResponses.
Subject - Record Class in io.kroxylicious.proxy.authentication
Represents an actor in the system.
Subject(Principal...) - Constructor for record class io.kroxylicious.proxy.authentication.Subject
Creates a subject from the given principals.
Subject(Set<Principal>) - Constructor for record class io.kroxylicious.proxy.authentication.Subject
Creates a subject from the given principal set.
SubjectBuildingException - Exception Class in io.kroxylicious.proxy.authentication
An exception to be thrown if a Subject cannot be built.
SubjectBuildingException(String) - Constructor for exception class io.kroxylicious.proxy.authentication.SubjectBuildingException
 
SubjectBuildingException(String, Throwable) - Constructor for exception class io.kroxylicious.proxy.authentication.SubjectBuildingException
 
SyncGroupRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for SyncGroupRequests.
SyncGroupResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for SyncGroupResponses.

T

TerminalStage<R> - Interface in io.kroxylicious.proxy.filter.filterresultbuilder
Interface supporting the FilterResultBuilder fluent API.
TerminalStage - Interface in io.kroxylicious.proxy.router
Terminal stage of the RouterContext builder API.
Terminology - Search tag in package io.kroxylicious.proxy.plugin
Section
Thread Safety - Search tag in interface io.kroxylicious.proxy.tls.ServerTlsCredentialSupplier
Section
Thread Safety - Search tag in package io.kroxylicious.proxy.filter
Section
Tls - Record Class in io.kroxylicious.proxy.config.tls
Provides TLS configuration for this peer.
Tls(KeyProvider, TrustProvider, AllowDeny<String>, AllowDeny<String>) - Constructor for record class io.kroxylicious.proxy.config.tls.Tls
Creates a Tls configuration without a TLS credential supplier.
Tls(KeyProvider, TrustProvider, AllowDeny<String>, AllowDeny<String>, TlsCredentialSupplierConfig) - Constructor for record class io.kroxylicious.proxy.config.tls.Tls
Compact constructor with validation.
TlsClientAuth - Enum Class in io.kroxylicious.proxy.config.tls
 
tlsCredentials(ServerTlsCredentialSupplierContext) - Method in interface io.kroxylicious.proxy.tls.ServerTlsCredentialSupplier
Asynchronously retrieves TLS credentials for the proxy to use when connecting to the target Kafka cluster.
tlsCredentials(PrivateKey, X509Certificate[]) - Method in interface io.kroxylicious.proxy.tls.ServerTlsCredentialSupplierContext
Creates a TlsCredentials instance from the given private key and certificate chain.
TlsCredentials - Interface in io.kroxylicious.proxy.tls
Represents TLS credentials (private key and certificate chain) that can be used for server-side TLS connections.
TlsCredentialSupplierConfig - Record Class in io.kroxylicious.proxy.config.tls
Configuration for a TLS credential supplier that dynamically provides TLS credentials.
TlsCredentialSupplierConfig(String, Object) - Constructor for record class io.kroxylicious.proxy.config.tls.TlsCredentialSupplierConfig
Validates that the type is non-null.
TopicLevelMetadataErrorException - Exception Class in io.kroxylicious.proxy.filter.metadata
Indicates that there was an Error set on a MetadataResponseData.MetadataResponseTopic.
TopicLevelMetadataErrorException(Errors) - Constructor for exception class io.kroxylicious.proxy.filter.metadata.TopicLevelMetadataErrorException
 
TopicNameMapping - Interface in io.kroxylicious.proxy.filter.metadata
The result of discovering the topic names for a collection of topic ids
TopicNameMappingException - Exception Class in io.kroxylicious.proxy.filter.metadata
Indicates there was some problem obtaining a name for a topic id
TopicNameMappingException(Errors) - Constructor for exception class io.kroxylicious.proxy.filter.metadata.TopicNameMappingException
 
TopicNameMappingException(Errors, String) - Constructor for exception class io.kroxylicious.proxy.filter.metadata.TopicNameMappingException
 
TopicNameMappingException(Errors, String, Throwable) - Constructor for exception class io.kroxylicious.proxy.filter.metadata.TopicNameMappingException
 
topicNames() - Method in interface io.kroxylicious.proxy.filter.metadata.TopicNameMapping
 
topicNames(String, Set<Uuid>) - Method in interface io.kroxylicious.proxy.topology.TopologyService
Resolves topic IDs to topic names for a given route, batching cache misses into a single METADATA request.
topicNames(Collection<Uuid>) - Method in interface io.kroxylicious.proxy.filter.FilterContext
Attempts to map all the given topicIds to the current corresponding topic names.
TopLevelMetadataErrorException - Exception Class in io.kroxylicious.proxy.filter.metadata
Indicates that there was an Error set at the top level of MetadataResponseData.
TopLevelMetadataErrorException(Errors) - Constructor for exception class io.kroxylicious.proxy.filter.metadata.TopLevelMetadataErrorException
 
topologyService() - Method in interface io.kroxylicious.proxy.router.RouterFactoryContext
Returns a TopologyService for this router level.
TopologyService - Interface in io.kroxylicious.proxy.topology
Opt-in topology cache for routers that need leader, coordinator, broker, or topic ID information.
toString() - Method in record class io.kroxylicious.proxy.authentication.Subject
Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.authentication.User
Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.secret.FilePassword
Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.secret.InlinePassword
Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.tls.AllowDeny
Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.tls.InsecureTls
Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.tls.KeyPair
Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.tls.KeyStore
Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.tls.ServerOptions
Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.tls.Tls
Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.tls.TlsCredentialSupplierConfig
Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.tls.TrustStore
Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.topology.BrokerInfo
Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.topology.PartitionInfo
Returns a string representation of this record class.
TransportSubjectBuilder - Interface in io.kroxylicious.proxy.authentication
Builds a Subject based on information available at the transport layer, before any requests have been received from the client.
TransportSubjectBuilder.Context - Interface in io.kroxylicious.proxy.authentication
 
TransportSubjectBuilderService<C> - Interface in io.kroxylicious.proxy.authentication
The service interface used to construct a TransportSubjectBuilder.
trust() - Method in record class io.kroxylicious.proxy.config.tls.Tls
Returns the value of the trust record component.
trustOptions() - Method in interface io.kroxylicious.proxy.config.tls.TrustProvider
Trust options that apply to this TLS peer..
trustOptions() - Method in record class io.kroxylicious.proxy.config.tls.TrustStore
Returns the value of the trustOptions record component.
TrustOptions - Interface in io.kroxylicious.proxy.config.tls
 
TrustProvider - Interface in io.kroxylicious.proxy.config.tls
A TrustProvider is a source of trust anchors used to determine whether a certificate present by a peer is trusted.
TrustProviderVisitor<T> - Interface in io.kroxylicious.proxy.config.tls
Visitor for implementations of TrustProvider
TrustStore - Record Class in io.kroxylicious.proxy.config.tls
A TrustProvider backed by a Java Truststore.
TrustStore(String, PasswordProvider, String) - Constructor for record class io.kroxylicious.proxy.config.tls.TrustStore
A TrustProvider backed by a Java Truststore.
TrustStore(String, PasswordProvider, String, TrustOptions) - Constructor for record class io.kroxylicious.proxy.config.tls.TrustStore
Creates an instance of a TrustStore record class.
TxnOffsetCommitRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for TxnOffsetCommitRequests.
TxnOffsetCommitResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for TxnOffsetCommitResponses.
type() - Method in record class io.kroxylicious.proxy.config.tls.TlsCredentialSupplierConfig
Returns the value of the type record component.

U

Unique - Annotation Interface in io.kroxylicious.proxy.authentication
Annotates implementations Principal which are only intended to have a single instance present in a Subject's principals.
uniquePrincipalOfType(Class<P>) - Method in record class io.kroxylicious.proxy.authentication.Subject
Returns the unique principal of the given type, if present.
UnknownPluginInstanceException - Exception Class in io.kroxylicious.proxy.plugin
A reference to a plugin instance could not be resolved by the proxy runtime.
UnknownPluginInstanceException(String) - Constructor for exception class io.kroxylicious.proxy.plugin.UnknownPluginInstanceException
 
UnknownPluginInstanceException(String, Throwable) - Constructor for exception class io.kroxylicious.proxy.plugin.UnknownPluginInstanceException
 
UnregisterBrokerRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for UnregisterBrokerRequests.
UnregisterBrokerResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for UnregisterBrokerResponses.
UpdateFeaturesRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for UpdateFeaturesRequests.
UpdateFeaturesResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for UpdateFeaturesResponses.
UpdateRaftVoterRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for UpdateRaftVoterRequests.
UpdateRaftVoterResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for UpdateRaftVoterResponses.
Usage Example - Search tag in interface io.kroxylicious.proxy.tls.ServerTlsCredentialSupplierContext
Section
Usage Example - Search tag in interface io.kroxylicious.proxy.tls.ServerTlsCredentialSupplierFactoryContext
Section
Usage Example - Search tag in interface io.kroxylicious.proxy.tls.TlsCredentials
Section
Usage Example: Client-Specific Credentials - Search tag in interface io.kroxylicious.proxy.tls.ServerTlsCredentialSupplier
Section
Usage Example: File-Based Credential Loading - Search tag in interface io.kroxylicious.proxy.tls.ServerTlsCredentialSupplier
Section
Usage Example: Simple File-Based Supplier - Search tag in interface io.kroxylicious.proxy.tls.ServerTlsCredentialSupplierFactory
Section
Usage Example: Supplier with Shared Resources - Search tag in interface io.kroxylicious.proxy.tls.ServerTlsCredentialSupplierFactory
Section
User - Record Class in io.kroxylicious.proxy.authentication
A principal identifying an authenticated client.
User(String) - Constructor for record class io.kroxylicious.proxy.authentication.User
Creates an instance of a User record class.
UserFactory - Class in io.kroxylicious.proxy.authentication
 
UserFactory() - Constructor for class io.kroxylicious.proxy.authentication.UserFactory
 
Using a plugin implementation - Search tag in package io.kroxylicious.proxy.plugin
Section

V

value() - Element in annotation interface io.kroxylicious.proxy.plugin.PluginImplName
The class reflecting the plugin interface (e.g.
valueOf(String) - Static method in enum class io.kroxylicious.proxy.config.tls.TlsClientAuth
Returns the enum constant of this class with the specified name.
values() - Static method in enum class io.kroxylicious.proxy.config.tls.TlsClientAuth
Returns an array containing the constants of this enum class, in the order they are declared.
virtualClusterName() - Method in interface io.kroxylicious.proxy.router.RouterFactoryContext
Returns the name of the virtual cluster that owns this router.
virtualNode() - Method in interface io.kroxylicious.proxy.router.RouterContext
Returns the virtual node of the broker that the client connected to.
VirtualNode - Interface in io.kroxylicious.proxy.topology
Opaque reference to a node in the virtual cluster topology.
visit(InsecureTls) - Method in interface io.kroxylicious.proxy.config.tls.TrustProviderVisitor
 
visit(KeyPair) - Method in interface io.kroxylicious.proxy.config.tls.KeyProviderVisitor
 
visit(KeyStore) - Method in interface io.kroxylicious.proxy.config.tls.KeyProviderVisitor
 
visit(PlatformTrustProvider) - Method in interface io.kroxylicious.proxy.config.tls.TrustProviderVisitor
 
visit(TrustStore) - Method in interface io.kroxylicious.proxy.config.tls.TrustProviderVisitor
 
VoteRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for VoteRequests.
VoteResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for VoteResponses.

W

withCloseConnection() - Method in interface io.kroxylicious.proxy.filter.filterresultbuilder.CloseStage
Signals the desire of the filter that the connection is closed.
withCloseConnection() - Method in interface io.kroxylicious.proxy.router.CloseStage
Signals that the client connection should be closed after the result is delivered.
WriteShareGroupStateRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for WriteShareGroupStateRequests.
WriteShareGroupStateResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for WriteShareGroupStateResponses.
WriteTxnMarkersRequestFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for WriteTxnMarkersRequests.
WriteTxnMarkersResponseFilter - Interface in io.kroxylicious.proxy.filter
A stateless filter for WriteTxnMarkersResponses.
A B C D E F G H I J K L M N O P R S T U V W 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form