Index
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
AllowDenyrecord class. - allowed() - Method in record class io.kroxylicious.proxy.config.tls.AllowDeny
-
Returns the value of the
allowedrecord 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
BrokerInforecord 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
Subjectbuilt from the givencontext. - buildTransportSubject(TransportSubjectBuilder.Context) - Method in interface io.kroxylicious.proxy.authentication.TransportSubjectBuilder
-
Returns an asynchronous result which completes with the
Subjectbuilt from the givencontext.
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
certificateFilerecord 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
cipherSuitesrecord component. - clientAuth() - Method in record class io.kroxylicious.proxy.config.tls.ServerOptions
-
Returns the value of the
clientAuthrecord 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
FilterResultBuilderfluent API. - CloseOrTerminalStage - Interface in io.kroxylicious.proxy.router
-
Combined stage of the
RouterContextbuilder API that allows both closing the connection and building the result. - CloseStage<R> - Interface in io.kroxylicious.proxy.filter.filterresultbuilder
-
Interface supporting the
FilterResultBuilderfluent API. - CloseStage - Interface in io.kroxylicious.proxy.router
-
Stage of the
RouterContextbuilder 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
configrecord 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
-
A snapshot of coordinator assignments, returned by
TopologyService.coordinators(java.lang.String, byte, java.util.Set<java.lang.String>). - 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
credentialSupplierrecord 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
deniedrecord 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
FilePasswordrecord 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
Filterinstances. - 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
hostrecord 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
InlinePasswordrecord class. - insecure() - Method in record class io.kroxylicious.proxy.config.tls.InsecureTls
-
Returns the value of the
insecurerecord component. - InsecureTls - Record Class in io.kroxylicious.proxy.config.tls
-
A
TrustProviderthat allows the disabling trust verification. - InsecureTls(boolean) - Constructor for record class io.kroxylicious.proxy.config.tls.InsecureTls
-
Creates an instance of a
InsecureTlsrecord 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
isrrecord 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
keyrecord component. - KeyPair - Record Class in io.kroxylicious.proxy.config.tls
-
A
KeyProviderbacked 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
KeyPairrecord class. - keyPasswordProvider() - Method in record class io.kroxylicious.proxy.config.tls.KeyPair
-
Returns the value of the
keyPasswordProviderrecord component. - keyPasswordProvider() - Method in record class io.kroxylicious.proxy.config.tls.KeyStore
-
Returns the value of the
keyPasswordProviderrecord 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
KeyProviderbacked by a Java Truststore. - KeyStore(String, PasswordProvider, PasswordProvider, String) - Constructor for record class io.kroxylicious.proxy.config.tls.KeyStore
-
Creates an instance of a
KeyStorerecord class.
L
- leader() - Method in record class io.kroxylicious.proxy.topology.PartitionInfo
-
Returns the value of the
leaderrecord 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
namerecord 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
headerandrequestpair, returning theheaderandrequestpair 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
headerandresponsepair, returning theheaderandresponsepair 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
-
A snapshot of partition leader assignments, returned by
TopologyService.leaders(java.util.Map<java.lang.String, java.util.Set<java.lang.String>>). - password() - Method in record class io.kroxylicious.proxy.config.secret.InlinePassword
-
Returns the value of the
passwordrecord component. - passwordFile() - Method in record class io.kroxylicious.proxy.config.secret.FilePassword
-
Returns the value of the
passwordFilerecord 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
portrecord 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
principalsrecord component. - privateKeyFile() - Method in record class io.kroxylicious.proxy.config.tls.KeyPair
-
Returns the value of the
privateKeyFilerecord 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
protocolsrecord 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
rackrecord 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
replicasrecord 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
FilterResultfor 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
configis not null, throwingPluginConfigurationExceptionif 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
FilterResultfor 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
-
Context passed to
Router.onRequest(org.apache.kafka.common.protocol.ApiKeys, short, org.apache.kafka.common.message.RequestHeaderData, org.apache.kafka.common.protocol.ApiMessage, io.kroxylicious.proxy.router.RouterContext)for issuing requests to named routes and constructing the routing outcome. - RouterFactory<C,
I> - Interface in io.kroxylicious.proxy.router -
A pluggable source of
Routerinstances. - RouterFactoryContext - Interface in io.kroxylicious.proxy.router
-
Context for
RouterFactoryinitialisation 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
Subjectbased 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
ServerOptionsrecord 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
ServerTlsCredentialSupplierinstances when TLS credentials are requested. - ServerTlsCredentialSupplierFactory<C,
I> - Interface in io.kroxylicious.proxy.tls -
A pluggable factory for creating
ServerTlsCredentialSupplierinstances. - ServerTlsCredentialSupplierFactoryContext - Interface in io.kroxylicious.proxy.tls
-
Construction context for
ServerTlsCredentialSupplierinstances. - 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
storeFilerecord component. - storeFile() - Method in record class io.kroxylicious.proxy.config.tls.TrustStore
-
Returns the value of the
storeFilerecord component. - storePasswordProvider() - Method in record class io.kroxylicious.proxy.config.tls.KeyStore
-
Returns the value of the
storePasswordProviderrecord component. - storePasswordProvider() - Method in record class io.kroxylicious.proxy.config.tls.TrustStore
-
Returns the value of the
storePasswordProviderrecord component. - storeType() - Method in record class io.kroxylicious.proxy.config.tls.KeyStore
-
Returns the value of the
storeTyperecord component. - storeType() - Method in record class io.kroxylicious.proxy.config.tls.TrustStore
-
Returns the value of the
storeTyperecord 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
Subjectcannot 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
FilterResultBuilderfluent API. - TerminalStage - Interface in io.kroxylicious.proxy.router
-
Terminal stage of the
RouterContextbuilder 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
TlsCredentialsinstance 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
Errorset on aMetadataResponseData.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
topicIdsto the current corresponding topic names. - TopLevelMetadataErrorException - Exception Class in io.kroxylicious.proxy.filter.metadata
-
Indicates that there was an
Errorset at the top level ofMetadataResponseData. - TopLevelMetadataErrorException(Errors) - Constructor for exception class io.kroxylicious.proxy.filter.metadata.TopLevelMetadataErrorException
- topologyService() - Method in interface io.kroxylicious.proxy.router.RouterFactoryContext
-
Returns a
TopologyServicefor 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
Subjectbased 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
trustrecord 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
trustOptionsrecord 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
TrustProviderbacked by a Java Truststore. - TrustStore(String, PasswordProvider, String) - Constructor for record class io.kroxylicious.proxy.config.tls.TrustStore
-
A
TrustProviderbacked by a Java Truststore. - TrustStore(String, PasswordProvider, String, TrustOptions) - Constructor for record class io.kroxylicious.proxy.config.tls.TrustStore
-
Creates an instance of a
TrustStorerecord 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
typerecord component.
U
- Unique - Annotation Interface in io.kroxylicious.proxy.authentication
- 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
Userrecord 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.
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
RequestFilter.onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext)instead.