Index (Proxy runtime 0.23.0 API)

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

A

AbstractDefinitionBuilder<D> - Class in io.kroxylicious.proxy.config
AbstractDefinitionBuilder(String) - Constructor for class io.kroxylicious.proxy.config.AbstractDefinitionBuilder
acquire() - Method in class io.kroxylicious.proxy.internal.util.ActivationToken: Attempts to increment the counter if it is in the INITIAL state.
ActivationToken - Class in io.kroxylicious.proxy.internal.util: A thread-safe state that ensures exactly-once increment and decrement operations.
ActivationToken(AtomicInteger) - Constructor for class io.kroxylicious.proxy.internal.util.ActivationToken
activeConnections() - Method in class io.kroxylicious.proxy.internal.VirtualClusterLifecycle
add(ByteBuf) - Method in class io.kroxylicious.proxy.frame.DecodedFrame
addGateway(String, NodeIdentificationStrategy, Optional<Tls>) - Method in class io.kroxylicious.proxy.model.VirtualClusterModel
AddOffsetsToTxnRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for AddOffsetsToTxnRequestFilter.
AddOffsetsToTxnRequestFilterInvoker(AddOffsetsToTxnRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.AddOffsetsToTxnRequestFilterInvoker
AddOffsetsToTxnResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for AddOffsetsToTxnResponseFilter.
AddOffsetsToTxnResponseFilterInvoker(AddOffsetsToTxnResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.AddOffsetsToTxnResponseFilterInvoker
AddPartitionsToTxnRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for AddPartitionsToTxnRequestFilter.
AddPartitionsToTxnRequestFilterInvoker(AddPartitionsToTxnRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.AddPartitionsToTxnRequestFilterInvoker
AddPartitionsToTxnResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for AddPartitionsToTxnResponseFilter.
AddPartitionsToTxnResponseFilterInvoker(AddPartitionsToTxnResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.AddPartitionsToTxnResponseFilterInvoker
addPrincipals() - Method in record class io.kroxylicious.proxy.internal.subject.DefaultSaslSubjectBuilderService.Config: Returns the value of the addPrincipals record component.
addPrincipals() - Method in record class io.kroxylicious.proxy.internal.subject.DefaultTransportSubjectBuilderService.Config: Returns the value of the addPrincipals record component.
AddRaftVoterRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for AddRaftVoterRequestFilter.
AddRaftVoterRequestFilterInvoker(AddRaftVoterRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.AddRaftVoterRequestFilterInvoker
AddRaftVoterResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for AddRaftVoterResponseFilter.
AddRaftVoterResponseFilterInvoker(AddRaftVoterResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.AddRaftVoterResponseFilterInvoker
addVirtualCluster(VirtualClusterModel) - Method in class io.kroxylicious.proxy.internal.VirtualClusterRegistry: Creates a VirtualClusterLifecycle in INITIALIZING for the given model.
admitToFilterChain(Object) - Method in class io.kroxylicious.proxy.internal.KafkaProxyFrontendHandler: Forward a message towards the Filter Chain
allocateBuffer(ChannelHandlerContext, RequestFrame, boolean) - Method in class io.kroxylicious.proxy.internal.codec.KafkaRequestEncoder: This has been overridden in order to use Frame.estimateEncodedSize() to pre-size correctly the holding buffer and save expensive enlarging to happen under the hood, during the encoding process.
allocateBuffer(ChannelHandlerContext, ResponseFrame, boolean) - Method in class io.kroxylicious.proxy.internal.codec.KafkaResponseEncoder: This has been overridden in order to use Frame.estimateEncodedSize() to pre-size correctly the holding buffer and save expensive enlarging to happen under the hood, during the encoding process.
allocateId() - Method in class io.kroxylicious.proxy.internal.CorrelationIdAllocator: Returns the next correlation ID in the range, wrapping to minInc after maxExc - 1.
AllocateProducerIdsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for AllocateProducerIdsRequestFilter.
AllocateProducerIdsRequestFilterInvoker(AllocateProducerIdsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.AllocateProducerIdsRequestFilterInvoker
AllocateProducerIdsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for AllocateProducerIdsResponseFilter.
AllocateProducerIdsResponseFilterInvoker(AllocateProducerIdsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.AllocateProducerIdsResponseFilterInvoker
ALLOWED - Enum constant in enum class io.kroxylicious.proxy.config.ProxyProtocolMode: Kroxylicious inspects the first bytes of each connection and automatically detects whether a PROXY protocol header is present.
AlterClientQuotasRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for AlterClientQuotasRequestFilter.
AlterClientQuotasRequestFilterInvoker(AlterClientQuotasRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.AlterClientQuotasRequestFilterInvoker
AlterClientQuotasResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for AlterClientQuotasResponseFilter.
AlterClientQuotasResponseFilterInvoker(AlterClientQuotasResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.AlterClientQuotasResponseFilterInvoker
AlterConfigsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for AlterConfigsRequestFilter.
AlterConfigsRequestFilterInvoker(AlterConfigsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.AlterConfigsRequestFilterInvoker
AlterConfigsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for AlterConfigsResponseFilter.
AlterConfigsResponseFilterInvoker(AlterConfigsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.AlterConfigsResponseFilterInvoker
AlterPartitionReassignmentsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for AlterPartitionReassignmentsRequestFilter.
AlterPartitionReassignmentsRequestFilterInvoker(AlterPartitionReassignmentsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.AlterPartitionReassignmentsRequestFilterInvoker
AlterPartitionReassignmentsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for AlterPartitionReassignmentsResponseFilter.
AlterPartitionReassignmentsResponseFilterInvoker(AlterPartitionReassignmentsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.AlterPartitionReassignmentsResponseFilterInvoker
AlterPartitionRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for AlterPartitionRequestFilter.
AlterPartitionRequestFilterInvoker(AlterPartitionRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.AlterPartitionRequestFilterInvoker
AlterPartitionResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for AlterPartitionResponseFilter.
AlterPartitionResponseFilterInvoker(AlterPartitionResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.AlterPartitionResponseFilterInvoker
AlterReplicaLogDirsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for AlterReplicaLogDirsRequestFilter.
AlterReplicaLogDirsRequestFilterInvoker(AlterReplicaLogDirsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.AlterReplicaLogDirsRequestFilterInvoker
AlterReplicaLogDirsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for AlterReplicaLogDirsResponseFilter.
AlterReplicaLogDirsResponseFilterInvoker(AlterReplicaLogDirsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.AlterReplicaLogDirsResponseFilterInvoker
AlterShareGroupOffsetsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for AlterShareGroupOffsetsRequestFilter.
AlterShareGroupOffsetsRequestFilterInvoker(AlterShareGroupOffsetsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.AlterShareGroupOffsetsRequestFilterInvoker
AlterShareGroupOffsetsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for AlterShareGroupOffsetsResponseFilter.
AlterShareGroupOffsetsResponseFilterInvoker(AlterShareGroupOffsetsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.AlterShareGroupOffsetsResponseFilterInvoker
AlterUserScramCredentialsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for AlterUserScramCredentialsRequestFilter.
AlterUserScramCredentialsRequestFilterInvoker(AlterUserScramCredentialsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.AlterUserScramCredentialsRequestFilterInvoker
AlterUserScramCredentialsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for AlterUserScramCredentialsResponseFilter.
AlterUserScramCredentialsResponseFilterInvoker(AlterUserScramCredentialsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.AlterUserScramCredentialsResponseFilterInvoker
API_KEY - Static variable in class io.kroxylicious.proxy.internal.codec.KafkaRequestEncoder
API_KEY_LABEL - Static variable in class io.kroxylicious.proxy.internal.util.Metrics
API_VERSION - Static variable in class io.kroxylicious.proxy.internal.codec.KafkaRequestEncoder
API_VERSION_LABEL - Static variable in class io.kroxylicious.proxy.internal.util.Metrics
apiKey() - Method in class io.kroxylicious.proxy.frame.DecodedFrame
apiKey() - Method in class io.kroxylicious.proxy.internal.codec.CorrelationManager.Correlation
apiKeyId() - Method in class io.kroxylicious.proxy.frame.BareSaslRequest
apiKeyId() - Method in class io.kroxylicious.proxy.frame.BareSaslResponse
apiKeyId() - Method in class io.kroxylicious.proxy.frame.DecodedFrame
apiKeyId() - Method in interface io.kroxylicious.proxy.frame.Frame: Api key id of this frame.
apiKeyId() - Method in class io.kroxylicious.proxy.frame.OpaqueFrame
apiVersion - Variable in class io.kroxylicious.proxy.frame.DecodedFrame
apiVersion() - Method in class io.kroxylicious.proxy.frame.BareSaslRequest
apiVersion() - Method in class io.kroxylicious.proxy.frame.BareSaslResponse
apiVersion() - Method in class io.kroxylicious.proxy.frame.DecodedFrame
apiVersion() - Method in interface io.kroxylicious.proxy.frame.Frame: Api version of this frame.
apiVersion() - Method in class io.kroxylicious.proxy.frame.OpaqueFrame
apiVersion() - Method in class io.kroxylicious.proxy.internal.codec.CorrelationManager.Correlation
ApiVersionsDowngradeFilter - Class in io.kroxylicious.proxy.internal.filter.impl
ApiVersionsDowngradeFilter(ApiVersionsServiceImpl) - Constructor for class io.kroxylicious.proxy.internal.filter.impl.ApiVersionsDowngradeFilter
ApiVersionsIntersectFilter - Class in io.kroxylicious.proxy.internal.filter.impl: Changes an API_VERSIONS response so that a client sees the intersection of supported version ranges for each API key.
ApiVersionsIntersectFilter(ApiVersionsServiceImpl) - Constructor for class io.kroxylicious.proxy.internal.filter.impl.ApiVersionsIntersectFilter
ApiVersionsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ApiVersionsRequestFilter.
ApiVersionsRequestFilterInvoker(ApiVersionsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ApiVersionsRequestFilterInvoker
ApiVersionsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ApiVersionsResponseFilter.
ApiVersionsResponseFilterInvoker(ApiVersionsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ApiVersionsResponseFilterInvoker
ApiVersionsServiceImpl - Class in io.kroxylicious.proxy.internal
ApiVersionsServiceImpl() - Constructor for class io.kroxylicious.proxy.internal.ApiVersionsServiceImpl
ApiVersionsServiceImpl(Map<ApiKeys, Short>) - Constructor for class io.kroxylicious.proxy.internal.ApiVersionsServiceImpl
apply(HttpRequest) - Method in class io.kroxylicious.proxy.internal.admin.PrometheusMetricsEndpoint
apply(SslContextBuilder) - Method in class io.kroxylicious.proxy.internal.tls.NettyTrustProvider
apply(String) - Method in class io.kroxylicious.proxy.internal.subject.IdentityMappingRule
apply(String) - Method in class io.kroxylicious.proxy.internal.subject.ReplaceMatchMappingRule
apply(List<HostPort>) - Method in interface io.kroxylicious.proxy.bootstrap.BootstrapSelectionStrategy
apply(List<HostPort>) - Method in class io.kroxylicious.proxy.bootstrap.RandomBootstrapSelectionStrategy
apply(List<HostPort>) - Method in class io.kroxylicious.proxy.bootstrap.RoundRobinBootstrapSelectionStrategy
arrayInvoker(Filter) - Static method in class io.kroxylicious.proxy.internal.filter.FilterInvokers: Create an invoker for this filter that avoids instanceof when deciding if the filter should be consulted/handle messages.
asn1Value - Variable in enum class io.kroxylicious.proxy.internal.subject.TlsCertificateExtractor.Asn1SanNameType
Assertions - Class in io.kroxylicious.proxy.internal.util
AssignReplicasToDirsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for AssignReplicasToDirsRequestFilter.
AssignReplicasToDirsRequestFilterInvoker(AssignReplicasToDirsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.AssignReplicasToDirsRequestFilterInvoker
AssignReplicasToDirsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for AssignReplicasToDirsResponseFilter.
AssignReplicasToDirsResponseFilterInvoker(AssignReplicasToDirsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.AssignReplicasToDirsResponseFilterInvoker
asString(String, int) - Static method in class io.kroxylicious.proxy.service.HostPort
authenticatedIdleTimeout() - Method in record class io.kroxylicious.proxy.config.NettySettings: Returns the value of the authenticatedIdleTimeout record component.
authenticatedSubject() - Method in class io.kroxylicious.proxy.internal.ClientConnectionStateMachine
authenticatedSubject() - Method in class io.kroxylicious.proxy.internal.ClientSubjectManager
authorizationId() - Method in class io.kroxylicious.proxy.internal.ClientSubjectManager
awaitTermination(long, TimeUnit) - Method in class io.kroxylicious.proxy.internal.NettyFilterDispatchExecutor

B

BadTlsCredentialsException - Exception Class in io.kroxylicious.proxy.internal.tls: Thrown when TLS credentials are invalid — for example, when a private key does not match the certificate, or when the certificate chain is structurally incorrect.
BadTlsCredentialsException(String) - Constructor for exception class io.kroxylicious.proxy.internal.tls.BadTlsCredentialsException
BadTlsCredentialsException(String, Throwable) - Constructor for exception class io.kroxylicious.proxy.internal.tls.BadTlsCredentialsException
BareSaslRequest - Class in io.kroxylicious.proxy.frame: Ancient versions of Kafka implemented SASL/GSSAPI by sending the token on the wire as length prefixed bytes (no Kafka protocol header).
BareSaslRequest(byte[], boolean) - Constructor for class io.kroxylicious.proxy.frame.BareSaslRequest
BareSaslResponse - Class in io.kroxylicious.proxy.frame: Ancient versions of Kafka implemented SASL/GSSAPI by sending the response on the wire as length prefixed bytes (no Kafka protocol header).
BareSaslResponse(byte[]) - Constructor for class io.kroxylicious.proxy.frame.BareSaslResponse
BeginQuorumEpochRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for BeginQuorumEpochRequestFilter.
BeginQuorumEpochRequestFilterInvoker(BeginQuorumEpochRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.BeginQuorumEpochRequestFilterInvoker
BeginQuorumEpochResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for BeginQuorumEpochResponseFilter.
BeginQuorumEpochResponseFilterInvoker(BeginQuorumEpochResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.BeginQuorumEpochResponseFilterInvoker
BijectiveNodeIdMapping - Record Class in io.kroxylicious.proxy.internal.routing: Bijective node ID mapping: V = id + S × t, where V is the virtual ID, t is the target node ID, S is the total number of routes, and id is the route's configured identifier.
BijectiveNodeIdMapping(Map<String, Integer>, int) - Constructor for record class io.kroxylicious.proxy.internal.routing.BijectiveNodeIdMapping: Creates an instance of a BijectiveNodeIdMapping record class.
bindAddress() - Method in record class io.kroxylicious.proxy.config.admin.ManagementConfiguration: Returns the value of the bindAddress record component.
binderNames() - Method in record class io.kroxylicious.proxy.micrometer.StandardBindersHook.StandardBindersHookConfig: Returns the value of the binderNames record component.
bindingAddress() - Method in record class io.kroxylicious.proxy.internal.net.Endpoint: Returns the value of the bindingAddress record component.
bindNettyAllocatorMetrics(ByteBufAllocator) - Static method in class io.kroxylicious.proxy.internal.util.Metrics
bindNettyEventExecutorMetrics(EventLoopGroup...) - Static method in class io.kroxylicious.proxy.internal.util.Metrics
body - Variable in class io.kroxylicious.proxy.frame.DecodedFrame
body() - Method in class io.kroxylicious.proxy.frame.DecodedFrame
BodyDecoder - Class in io.kroxylicious.proxy.internal.codec: Decodes Kafka Readable into an ApiMessage
BodyDecoder() - Constructor for class io.kroxylicious.proxy.internal.codec.BodyDecoder
BootstrapEndpointBinding - Record Class in io.kroxylicious.proxy.internal.net: A bootstrap binding.
BootstrapEndpointBinding(EndpointGateway) - Constructor for record class io.kroxylicious.proxy.internal.net.BootstrapEndpointBinding: Creates an instance of a BootstrapEndpointBinding record class.
BootstrapSelectionStrategy - Interface in io.kroxylicious.proxy.bootstrap: Strategy for selecting an upstream target from a given list of upstream targets for bootstrapping.
bootstrapServer() - Method in record class io.kroxylicious.proxy.config.TargetCluster
bootstrapServer() - Method in record class io.kroxylicious.proxy.internal.routing.UpstreamClusterModel
bootstrapServers() - Method in record class io.kroxylicious.proxy.config.ClusterDefinition: Returns the value of the bootstrapServers record component.
bootstrapServers() - Method in record class io.kroxylicious.proxy.config.TargetCluster: A list of host/port pairs to use for establishing the initial connection to the target (upstream) Kafka cluster.
bootstrapServersList() - Method in record class io.kroxylicious.proxy.config.TargetCluster
bootstrapServersList() - Method in record class io.kroxylicious.proxy.internal.routing.UpstreamClusterModel
BrokerAddressFilter - Class in io.kroxylicious.proxy.internal.filter.impl: An internal filter that rewrites broker addresses in all relevant responses to the corresponding proxy address.
BrokerAddressFilter(EndpointGateway, EndpointReconciler) - Constructor for class io.kroxylicious.proxy.internal.filter.impl.BrokerAddressFilter
BrokerEndpointBinding - Record Class in io.kroxylicious.proxy.internal.net: A broker specific endpoint binding.
BrokerEndpointBinding(EndpointGateway, HostPort, Integer) - Constructor for record class io.kroxylicious.proxy.internal.net.BrokerEndpointBinding: Creates an instance of a BrokerEndpointBinding record class.
BrokerHeartbeatRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for BrokerHeartbeatRequestFilter.
BrokerHeartbeatRequestFilterInvoker(BrokerHeartbeatRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.BrokerHeartbeatRequestFilterInvoker
BrokerHeartbeatResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for BrokerHeartbeatResponseFilter.
BrokerHeartbeatResponseFilterInvoker(BrokerHeartbeatResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.BrokerHeartbeatResponseFilterInvoker
BrokerRegistrationRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for BrokerRegistrationRequestFilter.
BrokerRegistrationRequestFilterInvoker(BrokerRegistrationRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.BrokerRegistrationRequestFilterInvoker
BrokerRegistrationResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for BrokerRegistrationResponseFilter.
BrokerRegistrationResponseFilterInvoker(BrokerRegistrationResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.BrokerRegistrationResponseFilterInvoker
buf - Variable in class io.kroxylicious.proxy.frame.OpaqueFrame: The message buffer excluding the frame size, including the header and body.
buf() - Method in class io.kroxylicious.proxy.frame.OpaqueFrame
buffer() - Method in class io.kroxylicious.proxy.internal.util.ByteBufOutputStream
build() - Method in class io.kroxylicious.proxy.config.AbstractDefinitionBuilder
build() - Method in class io.kroxylicious.proxy.internal.config.Features.FeaturesBuilder
build() - Method in class io.kroxylicious.proxy.internal.filter.RequestFilterResultBuilderImpl
build() - Method in class io.kroxylicious.proxy.internal.filter.ResponseFilterResultBuilderImpl
build() - Method in class io.kroxylicious.proxy.internal.subject.DefaultSaslSubjectBuilderService
build() - Method in class io.kroxylicious.proxy.internal.subject.DefaultTransportSubjectBuilderService
build(TargetCluster, PluginFactoryRegistry) - Static method in record class io.kroxylicious.proxy.internal.routing.UpstreamClusterModel: Builds a fully-resolved UpstreamClusterModel for the given target cluster, constructing the SSL context and TLS credential supplier manager from the cluster's TLS configuration.
build(CommonTagsHook.CommonTagsHookConfig) - Method in class io.kroxylicious.proxy.micrometer.CommonTagsHook
build(PauseDetectorHook.PauseDetectorHookConfig) - Method in class io.kroxylicious.proxy.micrometer.PauseDetectorHook
build(StandardBindersHook.StandardBindersHookConfig) - Method in class io.kroxylicious.proxy.micrometer.StandardBindersHook
build(String, Filter) - Static method in record class io.kroxylicious.proxy.internal.filter.FilterAndInvoker: Builds a list of invokers for a filter
build(T) - Method in interface io.kroxylicious.proxy.micrometer.MicrometerConfigurationHookService: Build a hook
builder() - Static method in class io.kroxylicious.proxy.internal.admin.RoutingHttpServer
builder() - Static method in class io.kroxylicious.proxy.internal.config.Features
builder(ByteBufferOutputStream, Compression, TimestampType, long) - Static method in class io.kroxylicious.proxy.internal.util.MemoryRecordsHelper
buildInternal(String, Map<String, Object>) - Method in class io.kroxylicious.proxy.config.AbstractDefinitionBuilder
buildNodeIdentificationStrategy(String) - Method in record class io.kroxylicious.proxy.config.VirtualClusterGateway
buildSaslSubject(SaslSubjectBuilder.Context) - Method in class io.kroxylicious.proxy.internal.subject.DefaultSubjectBuilder
buildSaslSubject(SaslSubjectBuilder.Context) - Method in class io.kroxylicious.proxy.internal.subject.SaslSubjectBuilderImpl
buildStrategy(String) - Method in interface io.kroxylicious.proxy.config.NodeIdentificationStrategyFactory
buildStrategy(String) - Method in class io.kroxylicious.proxy.config.PortIdentifiesNodeIdentificationStrategy
buildStrategy(String) - Method in class io.kroxylicious.proxy.config.SniHostIdentifiesNodeIdentificationStrategy
buildTransportSubject(TransportSubjectBuilder.Context) - Method in class io.kroxylicious.proxy.internal.subject.DefaultSubjectBuilder
byteBuf() - Method in class io.kroxylicious.proxy.internal.util.ByteBufOutputStream
ByteBufAccessor - Interface in io.kroxylicious.proxy.frame: Provides read and write access to byte buffer for serializing frames.
ByteBufAccessorImpl - Class in io.kroxylicious.proxy.internal.codec: An implementation of Kafka's Readable and Writable abstraction in terms of a Netty ByteBuf.
ByteBufAccessorImpl(ByteBuf) - Constructor for class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
ByteBufOutputStream - Class in io.kroxylicious.proxy.internal.util: This class has been introduced as a work-around to allow using pooled ByteBuf instances that are allowed to grow on demand while used on MemoryRecordsBuilder to create records (using MemoryRecordsHelper factory methods).
ByteBufOutputStream(ByteBuf) - Constructor for class io.kroxylicious.proxy.internal.util.ByteBufOutputStream
bytes() - Method in class io.kroxylicious.proxy.frame.BareSaslRequest
bytes() - Method in class io.kroxylicious.proxy.frame.BareSaslResponse

C

CacheConfiguration - Record Class in io.kroxylicious.proxy.config: Cache Configuration
CacheConfiguration(Integer, Duration, Duration) - Constructor for record class io.kroxylicious.proxy.config.CacheConfiguration: Creates an instance of a CacheConfiguration record class.
cause() - Method in record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Failed: Returns the value of the cause record component.
cause() - Method in record class io.kroxylicious.proxy.reload.ReconfigureError: Returns the value of the cause record component.
certificateChain() - Method in record class io.kroxylicious.proxy.internal.tls.TlsCredentialsImpl: Returns the value of the certificateChain record component.
CHANNEL_BINDINGS - Static variable in class io.kroxylicious.proxy.internal.net.EndpointRegistry
channelActive(ChannelHandlerContext) - Method in class io.kroxylicious.proxy.internal.KafkaProxyBackendHandler: Netty callback that upstream/server channel has successfully connected to the remote peer.
channelActive(ChannelHandlerContext) - Method in class io.kroxylicious.proxy.internal.KafkaProxyFrontendHandler: Netty callback to notify that the downstream/client channel has an active TCP connection.
channelId() - Method in class io.kroxylicious.proxy.internal.KafkaProxyFrontendHandler: Get the ID of the frontend channel if available.
channelInactive(ChannelHandlerContext) - Method in class io.kroxylicious.proxy.internal.HaProxyProtocolDetectionHandler
channelInactive(ChannelHandlerContext) - Method in class io.kroxylicious.proxy.internal.KafkaProxyBackendHandler: Netty callback to notify that the upstream/server channel TCP connection has disconnected.
channelInactive(ChannelHandlerContext) - Method in class io.kroxylicious.proxy.internal.KafkaProxyFrontendHandler: Netty callback to notify that the downstream/client channel TCP connection has disconnected.
channelRead(ChannelHandlerContext, Object) - Method in class io.kroxylicious.proxy.internal.FilterHandler: Handles inbound requests flowing toward the upstream broker.
channelRead(ChannelHandlerContext, Object) - Method in class io.kroxylicious.proxy.internal.HaProxyProtocolDetectionHandler
channelRead(ChannelHandlerContext, Object) - Method in class io.kroxylicious.proxy.internal.KafkaProxyBackendHandler: Netty callback that something has been read from the upstream/server channel.
channelRead(ChannelHandlerContext, Object) - Method in class io.kroxylicious.proxy.internal.KafkaProxyFrontendHandler: Netty callback that something has been read from the downstream/client channel.
channelRead(ChannelHandlerContext, Object) - Method in class io.kroxylicious.proxy.internal.ResponseOrderer
channelRead(ChannelHandlerContext, Object) - Method in class io.kroxylicious.proxy.internal.routing.RouterDispatchHandler
channelRead(ChannelHandlerContext, Object) - Method in class io.kroxylicious.proxy.internal.SaslV0RejectionHandler
channelRead0(ChannelHandlerContext, HAProxyMessage) - Method in class io.kroxylicious.proxy.internal.HaProxyMessageHandler
channelRead0(ChannelHandlerContext, HttpObject) - Method in class io.kroxylicious.proxy.internal.admin.RoutingHttpServer
channelReadComplete(ChannelHandlerContext) - Method in class io.kroxylicious.proxy.internal.admin.RoutingHttpServer
channelReadComplete(ChannelHandlerContext) - Method in class io.kroxylicious.proxy.internal.KafkaProxyBackendHandler: Invoked when the last message read by the current read operation has been consumed by KafkaProxyBackendHandler.channelRead(ChannelHandlerContext, Object).
channelRegistered(ChannelHandlerContext) - Method in class io.kroxylicious.proxy.internal.KafkaProxyBackendHandler: Netty callback that resources have been allocated for the channel.
channelWritabilityChanged(ChannelHandlerContext) - Method in class io.kroxylicious.proxy.internal.KafkaProxyBackendHandler: Propagates backpressure to the downstream/client connection by notifying the ServerConnectionStateMachine when the upstream/server connection blocks or unblocks.
channelWritabilityChanged(ChannelHandlerContext) - Method in class io.kroxylicious.proxy.internal.KafkaProxyFrontendHandler: Propagates backpressure to the upstream/server connection by notifying the ClientConnectionStateMachine when the downstream/client connection blocks or unblocks.
clear() - Static method in class io.kroxylicious.proxy.internal.util.Metrics
CLIENT_CLOSED - Enum constant in enum class io.kroxylicious.proxy.internal.ClientConnectionStateMachine.DisconnectCause: Client initiated connection close
CLIENT_TLS - Static variable in class io.kroxylicious.proxy.internal.util.StableKroxyliciousLinkGenerator
CLIENT_TLS_SAN_DIR_NAME - Static variable in class io.kroxylicious.proxy.internal.subject.DefaultTransportSubjectBuilderService
CLIENT_TLS_SAN_DNS_NAME - Static variable in class io.kroxylicious.proxy.internal.subject.DefaultTransportSubjectBuilderService
CLIENT_TLS_SAN_IP_ADDRESS - Static variable in class io.kroxylicious.proxy.internal.subject.DefaultTransportSubjectBuilderService
CLIENT_TLS_SAN_RFC822_NAME - Static variable in class io.kroxylicious.proxy.internal.subject.DefaultTransportSubjectBuilderService
CLIENT_TLS_SAN_URI - Static variable in class io.kroxylicious.proxy.internal.subject.DefaultTransportSubjectBuilderService
CLIENT_TLS_SUBJECT - Static variable in class io.kroxylicious.proxy.internal.subject.DefaultTransportSubjectBuilderService
clientCertificate() - Method in class io.kroxylicious.proxy.internal.ClientSubjectManager
clientChannel() - Method in class io.kroxylicious.proxy.internal.ClientConnectionStateMachine
ClientConnectionStateMachine - Class in io.kroxylicious.proxy.internal: The state machine for a single client's proxy session.
ClientConnectionStateMachine(EndpointBinding, TransportSubjectBuilder, KafkaSession) - Constructor for class io.kroxylicious.proxy.internal.ClientConnectionStateMachine
ClientConnectionStateMachine.DisconnectCause - Enum Class in io.kroxylicious.proxy.internal: Enumeration of disconnect causes for tracking client to proxy disconnections.
clientSaslAuthenticationFailure() - Method in class io.kroxylicious.proxy.internal.ClientConnectionStateMachine
clientSaslAuthenticationSuccess(String, Subject) - Method in class io.kroxylicious.proxy.internal.ClientConnectionStateMachine
clientSaslContext() - Method in class io.kroxylicious.proxy.internal.ClientConnectionStateMachine
clientSaslContext() - Method in class io.kroxylicious.proxy.internal.ClientSubjectManager
ClientSubjectManager - Class in io.kroxylicious.proxy.internal
clientTlsContext() - Method in class io.kroxylicious.proxy.internal.ClientConnectionStateMachine
clientTlsContext() - Method in class io.kroxylicious.proxy.internal.ClientSubjectManager
clientTlsContext() - Method in class io.kroxylicious.proxy.internal.tls.ServerTlsCredentialSupplierContextImpl
clientToProxyBackpressureTimer(String, Integer) - Static method in class io.kroxylicious.proxy.internal.util.Metrics
clientToProxyConnectionCounter(VirtualClusterNode) - Static method in class io.kroxylicious.proxy.internal.util.Metrics
clientToProxyConnectionCounter(String, Integer) - Static method in class io.kroxylicious.proxy.internal.util.Metrics
clientToProxyConnectionToken(VirtualClusterNode) - Static method in class io.kroxylicious.proxy.internal.util.Metrics
clientToProxyDisconnectsCounter(String, Integer, String) - Static method in class io.kroxylicious.proxy.internal.util.Metrics: Creates a counter for tracking client to proxy disconnections by cause.
clientToProxyErrorCounter(String, Integer) - Static method in class io.kroxylicious.proxy.internal.util.Metrics
clientToProxyMessageCounterProvider(String, Integer) - Static method in class io.kroxylicious.proxy.internal.util.Metrics
clientToProxyMessageSizeDistributionProvider(String, Integer) - Static method in class io.kroxylicious.proxy.internal.util.Metrics
close() - Method in class io.kroxylicious.proxy.bootstrap.FilterChainFactory
close() - Method in class io.kroxylicious.proxy.bootstrap.RouterChainFactory
close() - Method in class io.kroxylicious.proxy.bootstrap.TlsCredentialSupplierManager
close() - Method in class io.kroxylicious.proxy.internal.MeterRegistries
close() - Method in class io.kroxylicious.proxy.internal.net.DefaultNetworkBindingOperationProcessor
close() - Method in class io.kroxylicious.proxy.internal.net.EndpointRegistry
close() - Method in interface io.kroxylicious.proxy.internal.net.NetworkBindingOperationProcessor: Closes the processor.
close() - Method in record class io.kroxylicious.proxy.internal.routing.DirectRouting
close() - Method in record class io.kroxylicious.proxy.internal.routing.DynamicRouting
close() - Method in interface io.kroxylicious.proxy.internal.routing.RoutingModel
close() - Method in record class io.kroxylicious.proxy.internal.routing.UpstreamClusterModel
close() - Method in class io.kroxylicious.proxy.internal.subject.DefaultSaslSubjectBuilderService
close() - Method in class io.kroxylicious.proxy.internal.subject.DefaultTransportSubjectBuilderService
close() - Method in class io.kroxylicious.proxy.internal.VirtualClusterRegistry: Shuts down the lifecycle executor.
close() - Method in class io.kroxylicious.proxy.KafkaProxy
close() - Method in interface io.kroxylicious.proxy.micrometer.MicrometerConfigurationHook: Releases resources that may have been registered by this hook.
close() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel: Closes resources associated with this virtual cluster — the TLS credential supplier manager(s) held by the routing model and the FilterChainFactory.
cluster() - Method in record class io.kroxylicious.proxy.config.RouteDefinition
cluster() - Method in record class io.kroxylicious.proxy.config.RouteTarget: Returns the value of the cluster record component.
ClusterDefinition - Record Class in io.kroxylicious.proxy.config: A named cluster definition, referenced by routes and virtual clusters.
ClusterDefinition(String, String, Tls) - Constructor for record class io.kroxylicious.proxy.config.ClusterDefinition: Creates an instance of a ClusterDefinition record class.
clusterDefinitions() - Method in record class io.kroxylicious.proxy.config.Configuration: Returns the value of the clusterDefinitions record component.
clusterName() - Method in record class io.kroxylicious.proxy.internal.util.VirtualClusterNode: Returns the value of the clusterName record component.
clusterName() - Method in class io.kroxylicious.proxy.internal.VirtualClusterLifecycle
commitId() - Method in interface io.kroxylicious.proxy.VersionInfo
commitId() - Method in class io.kroxylicious.proxy.VersionInfo.Info
commonTags() - Method in record class io.kroxylicious.proxy.micrometer.CommonTagsHook.CommonTagsHookConfig: Returns the value of the commonTags record component.
CommonTagsHook - Class in io.kroxylicious.proxy.micrometer
CommonTagsHook() - Constructor for class io.kroxylicious.proxy.micrometer.CommonTagsHook
CommonTagsHook.CommonTagsHookConfig - Record Class in io.kroxylicious.proxy.micrometer
CommonTagsHookConfig(Map<String, String>) - Constructor for record class io.kroxylicious.proxy.micrometer.CommonTagsHook.CommonTagsHookConfig: Creates an instance of a CommonTagsHookConfig record class.
completed() - Method in class io.kroxylicious.proxy.internal.filter.FilterResultBuilderImpl
completeOnFilterDispatchThread(CompletionStage<T>) - Method in class io.kroxylicious.proxy.internal.NettyFilterDispatchExecutor
ConcurrentReconfigureException - Exception Class in io.kroxylicious.proxy.reload: Exceptional-completion cause for KafkaProxy.reconfigure(Configuration) when a second reconfigure call arrives while another is in progress.
ConcurrentReconfigureException() - Constructor for exception class io.kroxylicious.proxy.reload.ConcurrentReconfigureException
ConcurrentReconfigureException(String) - Constructor for exception class io.kroxylicious.proxy.reload.ConcurrentReconfigureException
config() - Method in record class io.kroxylicious.proxy.config.MicrometerDefinition: Returns the value of the config record component.
config() - Method in record class io.kroxylicious.proxy.config.NamedFilterDefinition: Returns the value of the config record component.
config() - Method in record class io.kroxylicious.proxy.config.RouterDefinition: Returns the value of the config record component.
config() - Method in record class io.kroxylicious.proxy.config.ServiceBasedPluginFactoryRegistry.ProviderAndConfigType: Returns the value of the config record component.
config() - Method in record class io.kroxylicious.proxy.config.TransportSubjectBuilderConfig: Returns the value of the config record component.
Config(List<PrincipalAdderConf>) - Constructor for record class io.kroxylicious.proxy.internal.subject.DefaultSaslSubjectBuilderService.Config: Creates an instance of a Config record class.
Config(List<PrincipalAdderConf>) - Constructor for record class io.kroxylicious.proxy.internal.subject.DefaultTransportSubjectBuilderService.Config: Creates an instance of a Config record class.
ConfigParser - Class in io.kroxylicious.proxy.config
ConfigParser() - Constructor for class io.kroxylicious.proxy.config.ConfigParser
configType(String) - Method in interface io.kroxylicious.proxy.config.PluginFactory: Resolves a plugin reference to the plugins config type.
Configuration - Record Class in io.kroxylicious.proxy.config: The root of the proxy configuration.
Configuration(ManagementConfiguration, List<ClusterDefinition>, List<NamedFilterDefinition>, List<String>, List<RouterDefinition>, List<VirtualCluster>, List<MicrometerDefinition>, boolean, Optional<Map<String, Object>>, NetworkDefinition, ProxyProtocolConfig) - Constructor for record class io.kroxylicious.proxy.config.Configuration: Creates an instance of configuration.
ConfigurationReloadOrchestrator - Class in io.kroxylicious.proxy.internal.reload: Internal class that owns the KafkaProxy.reconfigure(Configuration) pipeline.
ConfigurationReloadOrchestrator(Configuration, VirtualClusterRegistry, EndpointRegistry, List<ChangeDetector>) - Constructor for class io.kroxylicious.proxy.internal.reload.ConfigurationReloadOrchestrator
configure(MeterRegistry) - Method in interface io.kroxylicious.proxy.micrometer.MicrometerConfigurationHook: Configures this hook into the given registry.
configureCipherSuites(SslContextBuilder, Tls) - Static method in class io.kroxylicious.proxy.model.VirtualClusterModel
configureEnabledProtocols(SslContextBuilder, Tls) - Static method in class io.kroxylicious.proxy.model.VirtualClusterModel
configureTrustProvider(Tls) - Static method in class io.kroxylicious.proxy.model.VirtualClusterModel
ConsumerGroupDescribeRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ConsumerGroupDescribeRequestFilter.
ConsumerGroupDescribeRequestFilterInvoker(ConsumerGroupDescribeRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ConsumerGroupDescribeRequestFilterInvoker
ConsumerGroupDescribeResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ConsumerGroupDescribeResponseFilter.
ConsumerGroupDescribeResponseFilterInvoker(ConsumerGroupDescribeResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ConsumerGroupDescribeResponseFilterInvoker
ConsumerGroupHeartbeatRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ConsumerGroupHeartbeatRequestFilter.
ConsumerGroupHeartbeatRequestFilterInvoker(ConsumerGroupHeartbeatRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ConsumerGroupHeartbeatRequestFilterInvoker
ConsumerGroupHeartbeatResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ConsumerGroupHeartbeatResponseFilter.
ConsumerGroupHeartbeatResponseFilterInvoker(ConsumerGroupHeartbeatResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ConsumerGroupHeartbeatResponseFilterInvoker
containsTag(RequestHeaderData, RequestHeaderTagger.Tag) - Static method in class io.kroxylicious.proxy.internal.util.RequestHeaderTagger
ControllerRegistrationRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ControllerRegistrationRequestFilter.
ControllerRegistrationRequestFilterInvoker(ControllerRegistrationRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ControllerRegistrationRequestFilterInvoker
ControllerRegistrationResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ControllerRegistrationResponseFilter.
ControllerRegistrationResponseFilterInvoker(ControllerRegistrationResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ControllerRegistrationResponseFilterInvoker
correlationId - Variable in class io.kroxylicious.proxy.frame.DecodedFrame
correlationId - Variable in class io.kroxylicious.proxy.frame.OpaqueFrame
correlationId() - Method in class io.kroxylicious.proxy.frame.BareSaslRequest
correlationId() - Method in class io.kroxylicious.proxy.frame.BareSaslResponse
correlationId() - Method in class io.kroxylicious.proxy.frame.DecodedFrame
correlationId() - Method in interface io.kroxylicious.proxy.frame.Frame: The correlation id.
correlationId() - Method in class io.kroxylicious.proxy.frame.OpaqueFrame
CorrelationIdAllocator - Class in io.kroxylicious.proxy.internal: Allocates integer correlation IDs from a bounded circular range [minInc, maxExc).
CorrelationIdSpace - Class in io.kroxylicious.proxy.internal
CorrelationManager - Class in io.kroxylicious.proxy.internal.codec: Manages correlation ids for a single connection (across the proxy) between a single client and a single broker.
CorrelationManager() - Constructor for class io.kroxylicious.proxy.internal.codec.CorrelationManager
CorrelationManager(int) - Constructor for class io.kroxylicious.proxy.internal.codec.CorrelationManager
CorrelationManager.Correlation - Class in io.kroxylicious.proxy.internal.codec: A record for which responses should be decoded, together with their API key and version.
CreateAclsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for CreateAclsRequestFilter.
CreateAclsRequestFilterInvoker(CreateAclsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.CreateAclsRequestFilterInvoker
CreateAclsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for CreateAclsResponseFilter.
CreateAclsResponseFilterInvoker(CreateAclsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.CreateAclsResponseFilterInvoker
createBaseObjectMapper() - Static method in class io.kroxylicious.proxy.config.ConfigParser: A simple object mapper for parsing kroxylicious configuration, without our plugin loading extensions
CreateDelegationTokenRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for CreateDelegationTokenRequestFilter.
CreateDelegationTokenRequestFilterInvoker(CreateDelegationTokenRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.CreateDelegationTokenRequestFilterInvoker
CreateDelegationTokenResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for CreateDelegationTokenResponseFilter.
CreateDelegationTokenResponseFilterInvoker(CreateDelegationTokenResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.CreateDelegationTokenResponseFilterInvoker
createEndpoint(int, boolean) - Static method in record class io.kroxylicious.proxy.internal.net.Endpoint
createEndpoint(Channel, boolean) - Static method in record class io.kroxylicious.proxy.internal.net.Endpoint
createEndpoint(Optional<String>, int, boolean) - Static method in record class io.kroxylicious.proxy.internal.net.Endpoint
createFilters(FilterFactoryContext) - Method in class io.kroxylicious.proxy.bootstrap.FilterChainFactory: Creates a fresh list of Filter instances for the chain this factory was built with.
createObjectMapper() - Static method in class io.kroxylicious.proxy.config.ConfigParser
CreatePartitionsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for CreatePartitionsRequestFilter.
CreatePartitionsRequestFilterInvoker(CreatePartitionsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.CreatePartitionsRequestFilterInvoker
CreatePartitionsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for CreatePartitionsResponseFilter.
CreatePartitionsResponseFilterInvoker(CreatePartitionsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.CreatePartitionsResponseFilterInvoker
createResponseFrame(ResponseHeaderData, ApiMessage) - Method in class io.kroxylicious.proxy.frame.DecodedRequestFrame
createResponseFrame(ResponseHeaderData, ApiMessage) - Method in class io.kroxylicious.proxy.internal.InternalRequestFrame
createRouter() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel
createRouter(String) - Method in record class io.kroxylicious.proxy.internal.routing.DynamicRouting
createRouter(String, String) - Method in class io.kroxylicious.proxy.bootstrap.RouterChainFactory: Creates a new router instance for the given router name and virtual cluster.
createRouterAllocator() - Static method in class io.kroxylicious.proxy.internal.CorrelationIdSpace
CreateTopicsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for CreateTopicsRequestFilter.
CreateTopicsRequestFilterInvoker(CreateTopicsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.CreateTopicsRequestFilterInvoker
CreateTopicsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for CreateTopicsResponseFilter.
CreateTopicsResponseFilterInvoker(CreateTopicsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.CreateTopicsResponseFilterInvoker
currentState() - Method in class io.kroxylicious.proxy.internal.ClientConnectionStateMachine
currentState() - Method in class io.kroxylicious.proxy.internal.KafkaSession

D

deallocate() - Method in class io.kroxylicious.proxy.frame.DecodedFrame
decode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class io.kroxylicious.proxy.internal.codec.KafkaRequestDecoder
decode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class io.kroxylicious.proxy.internal.codec.KafkaResponseDecoder
DECODED_LABEL - Static variable in class io.kroxylicious.proxy.internal.util.Metrics
DecodedFrame<H,B> - Class in io.kroxylicious.proxy.frame: A frame that has been decoded (as opposed to an OpaqueFrame).
DecodedRequestFrame - Class in io.kroxylicious.proxy.frame: A decoded request frame.
DecodedRequestFrame(short, int, boolean, RequestHeaderData, B) - Constructor for class io.kroxylicious.proxy.frame.DecodedRequestFrame
DecodedResponseFrame - Class in io.kroxylicious.proxy.frame: A decoded response frame.
DecodedResponseFrame(short, int, ResponseHeaderData, B) - Constructor for class io.kroxylicious.proxy.frame.DecodedResponseFrame
decodeHeaderAndBody(ChannelHandlerContext, ByteBuf, int) - Method in class io.kroxylicious.proxy.internal.codec.KafkaRequestDecoder
decodeHeaderAndBody(ChannelHandlerContext, ByteBuf, int) - Method in class io.kroxylicious.proxy.internal.codec.KafkaResponseDecoder
DecodePredicate - Interface in io.kroxylicious.proxy.internal.codec: Encapsulates decisions about whether requests and responses should be fully deserialized into POJOs, or passed through as byte buffers with minimal deserialization.
decodeResponse() - Method in class io.kroxylicious.proxy.frame.BareSaslRequest
decodeResponse() - Method in class io.kroxylicious.proxy.frame.DecodedRequestFrame
decodeResponse() - Method in class io.kroxylicious.proxy.frame.OpaqueRequestFrame
decodeResponse() - Method in interface io.kroxylicious.proxy.frame.RequestFrame: Whether the response to this request should be decoded.
decodeResponse() - Method in class io.kroxylicious.proxy.internal.codec.CorrelationManager.Correlation
DEFAULT - Static variable in record class io.kroxylicious.proxy.config.CacheConfiguration
default_() - Method in record class io.kroxylicious.proxy.internal.subject.Rule: Returns the value of the default_ record component.
DEFAULT_BIND_ADDRESS - Static variable in record class io.kroxylicious.proxy.config.admin.ManagementConfiguration
DEFAULT_IDLE_SECONDS - Static variable in class io.kroxylicious.proxy.internal.KafkaProxyFrontendHandler
DEFAULT_IDLE_TIME_SECONDS - Static variable in class io.kroxylicious.proxy.internal.KafkaProxyFrontendHandler
DEFAULT_MANAGEMENT_PORT - Static variable in record class io.kroxylicious.proxy.config.admin.ManagementConfiguration
DEFAULT_SOCKET_FRAME_MAX_SIZE_BYTES - Static variable in class io.kroxylicious.proxy.model.VirtualClusterModel
defaultDetectors() - Static method in class io.kroxylicious.proxy.internal.reload.ConfigurationReloadOrchestrator: The production-default set of change detectors: VirtualClusterChangeDetector and FilterChangeDetector.
defaultFeatures() - Static method in class io.kroxylicious.proxy.internal.config.Features
defaultFilters() - Method in record class io.kroxylicious.proxy.config.Configuration: Returns the value of the defaultFilters record component.
DefaultNetworkBindingOperationProcessor - Class in io.kroxylicious.proxy.internal.net
DefaultNetworkBindingOperationProcessor() - Constructor for class io.kroxylicious.proxy.internal.net.DefaultNetworkBindingOperationProcessor
DefaultSaslSubjectBuilderService - Class in io.kroxylicious.proxy.internal.subject
DefaultSaslSubjectBuilderService() - Constructor for class io.kroxylicious.proxy.internal.subject.DefaultSaslSubjectBuilderService
DefaultSaslSubjectBuilderService.Config - Record Class in io.kroxylicious.proxy.internal.subject
DefaultSubjectBuilder - Class in io.kroxylicious.proxy.internal.subject
DefaultSubjectBuilder(List<PrincipalAdder>) - Constructor for class io.kroxylicious.proxy.internal.subject.DefaultSubjectBuilder
DefaultTransportSubjectBuilderService - Class in io.kroxylicious.proxy.internal.subject
DefaultTransportSubjectBuilderService() - Constructor for class io.kroxylicious.proxy.internal.subject.DefaultTransportSubjectBuilderService
DefaultTransportSubjectBuilderService.Config - Record Class in io.kroxylicious.proxy.internal.subject
DeleteAclsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DeleteAclsRequestFilter.
DeleteAclsRequestFilterInvoker(DeleteAclsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DeleteAclsRequestFilterInvoker
DeleteAclsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DeleteAclsResponseFilter.
DeleteAclsResponseFilterInvoker(DeleteAclsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DeleteAclsResponseFilterInvoker
DeleteGroupsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DeleteGroupsRequestFilter.
DeleteGroupsRequestFilterInvoker(DeleteGroupsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DeleteGroupsRequestFilterInvoker
DeleteGroupsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DeleteGroupsResponseFilter.
DeleteGroupsResponseFilterInvoker(DeleteGroupsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DeleteGroupsResponseFilterInvoker
DeleteRecordsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DeleteRecordsRequestFilter.
DeleteRecordsRequestFilterInvoker(DeleteRecordsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DeleteRecordsRequestFilterInvoker
DeleteRecordsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DeleteRecordsResponseFilter.
DeleteRecordsResponseFilterInvoker(DeleteRecordsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DeleteRecordsResponseFilterInvoker
DeleteShareGroupOffsetsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DeleteShareGroupOffsetsRequestFilter.
DeleteShareGroupOffsetsRequestFilterInvoker(DeleteShareGroupOffsetsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DeleteShareGroupOffsetsRequestFilterInvoker
DeleteShareGroupOffsetsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DeleteShareGroupOffsetsResponseFilter.
DeleteShareGroupOffsetsResponseFilterInvoker(DeleteShareGroupOffsetsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DeleteShareGroupOffsetsResponseFilterInvoker
DeleteShareGroupStateRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DeleteShareGroupStateRequestFilter.
DeleteShareGroupStateRequestFilterInvoker(DeleteShareGroupStateRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DeleteShareGroupStateRequestFilterInvoker
DeleteShareGroupStateResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DeleteShareGroupStateResponseFilter.
DeleteShareGroupStateResponseFilterInvoker(DeleteShareGroupStateResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DeleteShareGroupStateResponseFilterInvoker
DeleteTopicsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DeleteTopicsRequestFilter.
DeleteTopicsRequestFilterInvoker(DeleteTopicsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DeleteTopicsRequestFilterInvoker
DeleteTopicsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DeleteTopicsResponseFilter.
DeleteTopicsResponseFilterInvoker(DeleteTopicsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DeleteTopicsResponseFilterInvoker
DenyCipherSuiteFilter - Class in io.kroxylicious.proxy.model: This class has been built to filter cipher suites based on requirements for Kroxylicious If no ciphers are declared then the default platform ciphers will be used If ciphers are declared then they are used instead of the default platform ciphers Both lists would then have anything removed that wasn't supported or in the deniedCiphers
DenyCipherSuiteFilter(Set<String>) - Constructor for class io.kroxylicious.proxy.model.DenyCipherSuiteFilter
deregisterConnection(ClientConnectionStateMachine) - Method in class io.kroxylicious.proxy.internal.VirtualClusterLifecycle
deregisterConnection(String, ClientConnectionStateMachine) - Method in class io.kroxylicious.proxy.internal.VirtualClusterRegistry: Decrements the active-connections count for clusterName if the cluster is no longer known to this registry.
deregisterVirtualCluster(EndpointGateway) - Method in class io.kroxylicious.proxy.internal.net.EndpointRegistry: De-registers a virtual cluster from the registry, removing all existing endpoint bindings, and closing any listening sockets that are no longer required.
DescribeAclsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeAclsRequestFilter.
DescribeAclsRequestFilterInvoker(DescribeAclsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeAclsRequestFilterInvoker
DescribeAclsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeAclsResponseFilter.
DescribeAclsResponseFilterInvoker(DescribeAclsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeAclsResponseFilterInvoker
DescribeClientQuotasRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeClientQuotasRequestFilter.
DescribeClientQuotasRequestFilterInvoker(DescribeClientQuotasRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeClientQuotasRequestFilterInvoker
DescribeClientQuotasResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeClientQuotasResponseFilter.
DescribeClientQuotasResponseFilterInvoker(DescribeClientQuotasResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeClientQuotasResponseFilterInvoker
DescribeClusterRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeClusterRequestFilter.
DescribeClusterRequestFilterInvoker(DescribeClusterRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeClusterRequestFilterInvoker
DescribeClusterResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeClusterResponseFilter.
DescribeClusterResponseFilterInvoker(DescribeClusterResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeClusterResponseFilterInvoker
DescribeConfigsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeConfigsRequestFilter.
DescribeConfigsRequestFilterInvoker(DescribeConfigsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeConfigsRequestFilterInvoker
DescribeConfigsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeConfigsResponseFilter.
DescribeConfigsResponseFilterInvoker(DescribeConfigsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeConfigsResponseFilterInvoker
DescribeDelegationTokenRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeDelegationTokenRequestFilter.
DescribeDelegationTokenRequestFilterInvoker(DescribeDelegationTokenRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeDelegationTokenRequestFilterInvoker
DescribeDelegationTokenResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeDelegationTokenResponseFilter.
DescribeDelegationTokenResponseFilterInvoker(DescribeDelegationTokenResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeDelegationTokenResponseFilterInvoker
DescribeGroupsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeGroupsRequestFilter.
DescribeGroupsRequestFilterInvoker(DescribeGroupsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeGroupsRequestFilterInvoker
DescribeGroupsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeGroupsResponseFilter.
DescribeGroupsResponseFilterInvoker(DescribeGroupsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeGroupsResponseFilterInvoker
DescribeLogDirsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeLogDirsRequestFilter.
DescribeLogDirsRequestFilterInvoker(DescribeLogDirsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeLogDirsRequestFilterInvoker
DescribeLogDirsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeLogDirsResponseFilter.
DescribeLogDirsResponseFilterInvoker(DescribeLogDirsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeLogDirsResponseFilterInvoker
DescribeProducersRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeProducersRequestFilter.
DescribeProducersRequestFilterInvoker(DescribeProducersRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeProducersRequestFilterInvoker
DescribeProducersResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeProducersResponseFilter.
DescribeProducersResponseFilterInvoker(DescribeProducersResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeProducersResponseFilterInvoker
DescribeQuorumRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeQuorumRequestFilter.
DescribeQuorumRequestFilterInvoker(DescribeQuorumRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeQuorumRequestFilterInvoker
DescribeQuorumResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeQuorumResponseFilter.
DescribeQuorumResponseFilterInvoker(DescribeQuorumResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeQuorumResponseFilterInvoker
DescribeShareGroupOffsetsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeShareGroupOffsetsRequestFilter.
DescribeShareGroupOffsetsRequestFilterInvoker(DescribeShareGroupOffsetsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeShareGroupOffsetsRequestFilterInvoker
DescribeShareGroupOffsetsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeShareGroupOffsetsResponseFilter.
DescribeShareGroupOffsetsResponseFilterInvoker(DescribeShareGroupOffsetsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeShareGroupOffsetsResponseFilterInvoker
DescribeTopicPartitionsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeTopicPartitionsRequestFilter.
DescribeTopicPartitionsRequestFilterInvoker(DescribeTopicPartitionsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeTopicPartitionsRequestFilterInvoker
DescribeTopicPartitionsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeTopicPartitionsResponseFilter.
DescribeTopicPartitionsResponseFilterInvoker(DescribeTopicPartitionsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeTopicPartitionsResponseFilterInvoker
DescribeTransactionsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeTransactionsRequestFilter.
DescribeTransactionsRequestFilterInvoker(DescribeTransactionsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeTransactionsRequestFilterInvoker
DescribeTransactionsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeTransactionsResponseFilter.
DescribeTransactionsResponseFilterInvoker(DescribeTransactionsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeTransactionsResponseFilterInvoker
DescribeUserScramCredentialsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeUserScramCredentialsRequestFilter.
DescribeUserScramCredentialsRequestFilterInvoker(DescribeUserScramCredentialsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeUserScramCredentialsRequestFilterInvoker
DescribeUserScramCredentialsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for DescribeUserScramCredentialsResponseFilter.
DescribeUserScramCredentialsResponseFilterInvoker(DescribeUserScramCredentialsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.DescribeUserScramCredentialsResponseFilterInvoker
deserialize(JsonParser, DeserializationContext) - Method in class io.kroxylicious.proxy.config.DurationSerde.Deserializer
Deserializer() - Constructor for class io.kroxylicious.proxy.config.DurationSerde.Deserializer
destinationAddress() - Method in record class io.kroxylicious.proxy.internal.net.HaProxyContext: Returns the value of the destinationAddress record component.
destinationPort() - Method in record class io.kroxylicious.proxy.internal.net.HaProxyContext: Returns the value of the destinationPort record component.
development() - Method in record class io.kroxylicious.proxy.config.Configuration: Returns the value of the development record component.
DIR_NAME - Enum constant in enum class io.kroxylicious.proxy.internal.subject.TlsCertificateExtractor.Asn1SanNameType
DirectRouting - Record Class in io.kroxylicious.proxy.internal.routing: Routing model for a virtual cluster that forwards directly to a single, statically-configured upstream Kafka cluster.
DirectRouting(String, TargetCluster) - Constructor for record class io.kroxylicious.proxy.internal.routing.DirectRouting: Test-only constructor: creates a routing model with no TLS resources resolved.
DirectRouting(String, UpstreamClusterModel) - Constructor for record class io.kroxylicious.proxy.internal.routing.DirectRouting: Creates an instance of a DirectRouting record class.
DISABLED - Enum constant in enum class io.kroxylicious.proxy.config.ProxyProtocolMode: No PROXY protocol handling.
discoveryAddressMap() - Method in interface io.kroxylicious.proxy.internal.net.EndpointGateway: Map of node ids to broker addresses.
discoveryAddressMap() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel.VirtualClusterGatewayModel
discoveryAddressMap() - Method in interface io.kroxylicious.proxy.service.NodeIdentificationStrategy: Map of discovery addresses that will be bound by the virtual cluster on start-up (before the first reconcile has taken place).
DNS - Enum constant in enum class io.kroxylicious.proxy.internal.subject.TlsCertificateExtractor.Asn1SanNameType
downgradeApiVersionsFrame(int) - Static method in class io.kroxylicious.proxy.internal.filter.impl.ApiVersionsDowngradeFilter
downstreamCorrelationId() - Method in class io.kroxylicious.proxy.internal.codec.CorrelationManager.Correlation
DRAIN_COMPLETED - Enum constant in enum class io.kroxylicious.proxy.internal.ClientConnectionStateMachine.DisconnectCause: Connection closed after graceful drain completed (all in-flight requests responded)
DRAIN_TIMEOUT - Enum constant in enum class io.kroxylicious.proxy.internal.ClientConnectionStateMachine.DisconnectCause: Connection force-closed after drain timeout expired
drainComplete() - Method in class io.kroxylicious.proxy.internal.VirtualClusterLifecycle: Transitions from VirtualClusterLifecycleState.Draining to VirtualClusterLifecycleState.Stopped.
drainFuture() - Method in class io.kroxylicious.proxy.internal.VirtualClusterLifecycle: Returns the future that completes when all connections have drained.
Draining(Duration) - Constructor for record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Draining: Creates an instance of a Draining record class.
drainTimeout() - Method in record class io.kroxylicious.proxy.config.VirtualCluster: Returns the value of the drainTimeout record component.
drainTimeout() - Method in record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Draining: Returns the value of the drainTimeout record component.
drainTimeout() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel
drop() - Method in class io.kroxylicious.proxy.internal.filter.FilterResultBuilderImpl
DurationArithmeticException - Exception Class in io.kroxylicious.proxy.config: Thrown if there is some arithmetic exception constructing or operating on a Duration
DurationArithmeticException(String, ArithmeticException) - Constructor for exception class io.kroxylicious.proxy.config.DurationArithmeticException
DurationSerde - Class in io.kroxylicious.proxy.config
DurationSerde.Deserializer - Class in io.kroxylicious.proxy.config
DurationSerde.Serializer - Class in io.kroxylicious.proxy.config
DynamicRouting - Record Class in io.kroxylicious.proxy.internal.routing: Routing model for a virtual cluster that forwards to one or more upstream clusters via a named router plugin.
DynamicRouting(String, Map<String, RouteDescriptor>, RouterChainFactory) - Constructor for record class io.kroxylicious.proxy.internal.routing.DynamicRouting: Test-only constructor: uses an empty cluster model map.
DynamicRouting(String, Map<String, RouteDescriptor>, RouterChainFactory, Map<String, UpstreamClusterModel>) - Constructor for record class io.kroxylicious.proxy.internal.routing.DynamicRouting: Production constructor: computes the NodeIdMapping from the supplied route descriptors.
DynamicRouting(String, Map<String, RouteDescriptor>, NodeIdMapping, RouterChainFactory, Map<String, UpstreamClusterModel>) - Constructor for record class io.kroxylicious.proxy.internal.routing.DynamicRouting: Creates an instance of a DynamicRouting record class.

E

EagerMetadataLearner - Class in io.kroxylicious.proxy.internal.filter.impl: An internal filter that causes the system to eagerly learn the cluster's topology by spontaneously emitting an out-of-band Metadata request at the earliest legal point in the Kafka conversation.
EagerMetadataLearner() - Constructor for class io.kroxylicious.proxy.internal.filter.impl.EagerMetadataLearner: Create EagerMetadataLearner
ElectLeadersRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ElectLeadersRequestFilter.
ElectLeadersRequestFilterInvoker(ElectLeadersRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ElectLeadersRequestFilterInvoker
ElectLeadersResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ElectLeadersResponseFilter.
ElectLeadersResponseFilterInvoker(ElectLeadersResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ElectLeadersResponseFilterInvoker
else_() - Method in record class io.kroxylicious.proxy.internal.subject.Map: Returns the value of the else_ record component.
ELSE_ANONYMOUS - Static variable in class io.kroxylicious.proxy.internal.subject.DefaultSaslSubjectBuilderService
ELSE_ANONYMOUS - Static variable in class io.kroxylicious.proxy.internal.subject.DefaultTransportSubjectBuilderService
ELSE_ANONYMOUS - Static variable in class io.kroxylicious.proxy.internal.subject.IdentityMappingRule
ELSE_ANONYMOUS - Static variable in class io.kroxylicious.proxy.internal.subject.ReplaceMatchMappingRule
ELSE_IDENTITY - Static variable in class io.kroxylicious.proxy.internal.subject.DefaultSaslSubjectBuilderService
ELSE_IDENTITY - Static variable in class io.kroxylicious.proxy.internal.subject.DefaultTransportSubjectBuilderService
ELSE_IDENTITY - Static variable in class io.kroxylicious.proxy.internal.subject.IdentityMappingRule
ELSE_IDENTITY - Static variable in class io.kroxylicious.proxy.internal.subject.ReplaceMatchMappingRule
EMERGENCY_API_VERSION - Static variable in class io.kroxylicious.proxy.internal.codec.KafkaResponseDecoder
empty() - Static method in class io.kroxylicious.proxy.bootstrap.FilterChainFactory: Returns a FilterChainFactory with an empty filter chain, for callers that have no filters to apply and therefore no PluginFactoryRegistry to supply (for example virtual clusters that opt out of the default chain, and tests that do not exercise the chain).
enable(Feature) - Method in class io.kroxylicious.proxy.internal.config.Features.FeaturesBuilder
enabledByDefault() - Method in enum class io.kroxylicious.proxy.internal.config.Feature
encode(ByteBufAccessor) - Method in class io.kroxylicious.proxy.frame.BareSaslRequest
encode(ByteBufAccessor) - Method in class io.kroxylicious.proxy.frame.BareSaslResponse
encode(ByteBufAccessor) - Method in class io.kroxylicious.proxy.frame.DecodedFrame
encode(ByteBufAccessor) - Method in interface io.kroxylicious.proxy.frame.Frame: Write the frame, including the size prefix, to the given buffer
encode(ByteBufAccessor) - Method in class io.kroxylicious.proxy.frame.OpaqueFrame
encode(ChannelHandlerContext, ResponseFrame, ByteBuf) - Method in class io.kroxylicious.proxy.internal.codec.KafkaResponseEncoder
encode(ChannelHandlerContext, RequestFrame, ByteBuf) - Method in class io.kroxylicious.proxy.internal.codec.KafkaRequestEncoder
end() - Method in record class io.kroxylicious.proxy.config.NamedRange: Returns the value of the end record component.
endExclusive() - Method in record class io.kroxylicious.proxy.config.Range: Returns the value of the endExclusive record component.
Endpoint - Record Class in io.kroxylicious.proxy.internal.net: Represents a network endpoint.
Endpoint(Optional<String>, int, boolean) - Constructor for record class io.kroxylicious.proxy.internal.net.Endpoint: Creates an instance of a Endpoint record class.
EndpointBinding - Interface in io.kroxylicious.proxy.internal.net: An endpoint binding.
EndpointBindingException - Exception Class in io.kroxylicious.proxy.internal.net: Signals that an endpoint could not be bound due to an error condition.
EndpointBindingException(String) - Constructor for exception class io.kroxylicious.proxy.internal.net.EndpointBindingException
EndpointBindingException(String, Throwable) - Constructor for exception class io.kroxylicious.proxy.internal.net.EndpointBindingException
EndpointBindingResolver - Interface in io.kroxylicious.proxy.internal.net: Used by the KafkaProxyInitializer to resolve incoming channel metadata into a EndpointBinding.
EndpointException - Exception Class in io.kroxylicious.proxy.internal.net: This class is the general class of exceptions produced by failed endpoint operations.
EndpointException(String) - Constructor for exception class io.kroxylicious.proxy.internal.net.EndpointException
EndpointException(String, Throwable) - Constructor for exception class io.kroxylicious.proxy.internal.net.EndpointException
endpointGateway() - Method in record class io.kroxylicious.proxy.internal.net.BootstrapEndpointBinding: Returns the value of the endpointGateway record component.
endpointGateway() - Method in record class io.kroxylicious.proxy.internal.net.BrokerEndpointBinding: Returns the value of the endpointGateway record component.
endpointGateway() - Method in interface io.kroxylicious.proxy.internal.net.EndpointBinding: The endpoint listener.
endpointGateway() - Method in record class io.kroxylicious.proxy.internal.net.MetadataDiscoveryBrokerEndpointBinding: Returns the value of the endpointGateway record component.
EndpointGateway - Interface in io.kroxylicious.proxy.internal.net: A gateway to an endpoint.
EndpointReconciler - Interface in io.kroxylicious.proxy.internal.net
EndpointRegistry - Class in io.kroxylicious.proxy.internal.net: The endpoint registry is responsible for associating network endpoints with broker/bootstrap addresses of virtual clusters.
EndpointRegistry(NetworkBindingOperationProcessor) - Constructor for class io.kroxylicious.proxy.internal.net.EndpointRegistry
EndpointResolutionException - Exception Class in io.kroxylicious.proxy.internal.net: Signals that an endpoint could not be resolved into a known virtual cluster binding.
EndpointResolutionException(String) - Constructor for exception class io.kroxylicious.proxy.internal.net.EndpointResolutionException
EndpointResolutionException(String, Throwable) - Constructor for exception class io.kroxylicious.proxy.internal.net.EndpointResolutionException
endpoints() - Method in record class io.kroxylicious.proxy.config.admin.ManagementConfiguration: Returns the value of the endpoints record component.
EndpointsConfiguration - Record Class in io.kroxylicious.proxy.config.admin
EndpointsConfiguration(PrometheusMetricsConfig) - Constructor for record class io.kroxylicious.proxy.config.admin.EndpointsConfiguration: Creates an instance of a EndpointsConfiguration record class.
EndQuorumEpochRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for EndQuorumEpochRequestFilter.
EndQuorumEpochRequestFilterInvoker(EndQuorumEpochRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.EndQuorumEpochRequestFilterInvoker
EndQuorumEpochResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for EndQuorumEpochResponseFilter.
EndQuorumEpochResponseFilterInvoker(EndQuorumEpochResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.EndQuorumEpochResponseFilterInvoker
EndTxnRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for EndTxnRequestFilter.
EndTxnRequestFilterInvoker(EndTxnRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.EndTxnRequestFilterInvoker
EndTxnResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for EndTxnResponseFilter.
EndTxnResponseFilterInvoker(EndTxnResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.EndTxnResponseFilterInvoker
enqueueNetworkBindingEvent(NetworkBindingOperation<?>) - Method in class io.kroxylicious.proxy.internal.net.DefaultNetworkBindingOperationProcessor
enqueueNetworkBindingEvent(NetworkBindingOperation<?>) - Method in interface io.kroxylicious.proxy.internal.net.NetworkBindingOperationProcessor: Enqueues a network binding operation.
ensureRemaining(int) - Method in class io.kroxylicious.proxy.internal.util.ByteBufOutputStream
ensureWritable(int) - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
ensureWritable(int) - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
EnvelopeRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for EnvelopeRequestFilter.
EnvelopeRequestFilterInvoker(EnvelopeRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.EnvelopeRequestFilterInvoker
EnvelopeResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for EnvelopeResponseFilter.
EnvelopeResponseFilterInvoker(EnvelopeResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.EnvelopeResponseFilterInvoker
equals(Object) - Method in record class io.kroxylicious.proxy.config.admin.EndpointsConfiguration: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.admin.ManagementConfiguration: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.admin.PrometheusMetricsConfig: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.CacheConfiguration: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.ClusterDefinition: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.Configuration: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.MicrometerDefinition: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.NamedFilterDefinition: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.NamedRange: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.NettySettings: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.NetworkDefinition: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in class io.kroxylicious.proxy.config.PortIdentifiesNodeIdentificationStrategy
equals(Object) - Method in record class io.kroxylicious.proxy.config.ProxyProtocolConfig: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.Range: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.RouteDefinition: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.RouterDefinition: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.RouteTarget: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.ServiceBasedPluginFactoryRegistry.ProviderAndConfigType: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in class io.kroxylicious.proxy.config.SniHostIdentifiesNodeIdentificationStrategy
equals(Object) - Method in record class io.kroxylicious.proxy.config.TargetCluster: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.TransportSubjectBuilderConfig: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.VirtualCluster: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.config.VirtualClusterGateway: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in class io.kroxylicious.proxy.internal.codec.CorrelationManager.Correlation
equals(Object) - Method in class io.kroxylicious.proxy.internal.config.Features
equals(Object) - Method in record class io.kroxylicious.proxy.internal.filter.FilterAndInvoker: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.filter.HandleNothingFilterInvoker: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.filter.RequestFilterInvoker: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.filter.RequestResponseInvoker: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.filter.ResponseFilterInvoker: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.filter.SafeInvoker: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in class io.kroxylicious.proxy.internal.KafkaSession
equals(Object) - Method in record class io.kroxylicious.proxy.internal.net.BootstrapEndpointBinding: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.net.BrokerEndpointBinding: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.net.Endpoint: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.net.HaProxyContext: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.net.MetadataDiscoveryBrokerEndpointBinding: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.routing.BijectiveNodeIdMapping: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.routing.DirectRouting: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.routing.DynamicRouting: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.routing.IdentityNodeIdMapping: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.routing.NodeIdMapping.RouteAndNode: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.routing.RouteDescriptor: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.routing.UpstreamClusterModel: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.subject.DefaultSaslSubjectBuilderService.Config: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.subject.DefaultTransportSubjectBuilderService.Config: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.subject.Map: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.subject.PrincipalAdder: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.subject.PrincipalAdderConf: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.subject.Rule: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.tls.TlsCredentialsImpl: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.util.VirtualClusterNode: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Draining: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Failed: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Initializing: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Serving: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Stopped: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.micrometer.CommonTagsHook.CommonTagsHookConfig: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.micrometer.PauseDetectorHook.PauseDetectorHookConfig: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.micrometer.StandardBindersHook.StandardBindersHookConfig: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.kroxylicious.proxy.reload.ReconfigureError: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in class io.kroxylicious.proxy.service.HostPort
errorLink(String) - Method in class io.kroxylicious.proxy.internal.util.StableKroxyliciousLinkGenerator
errorResponse(RequestHeaderData, ApiMessage, ApiException) - Method in class io.kroxylicious.proxy.internal.filter.RequestFilterResultBuilderImpl
errorResponseForMessage(RequestHeaderData, ApiMessage, ApiException) - Static method in class io.kroxylicious.proxy.internal.KafkaProxyExceptionMapper
errorResponseMessage(DecodedRequestFrame<?>, Throwable) - Static method in class io.kroxylicious.proxy.internal.KafkaProxyExceptionMapper
errors() - Method in interface io.kroxylicious.proxy.reload.ReconfigureResult: Returns the per-component failures encountered while reconfiguring.
ESTABLISHING - Enum constant in enum class io.kroxylicious.proxy.internal.KafkaSessionState: The proxy has seen a connection, but it is not yet connected to an upstream node and ready for RPCs.
estimateEncodedSize() - Method in class io.kroxylicious.proxy.frame.BareSaslRequest
estimateEncodedSize() - Method in class io.kroxylicious.proxy.frame.BareSaslResponse
estimateEncodedSize() - Method in class io.kroxylicious.proxy.frame.DecodedFrame
estimateEncodedSize() - Method in interface io.kroxylicious.proxy.frame.Frame: Estimate the expected encoded size in bytes of this Frame.
In particular, written data by Frame.encode(ByteBufAccessor) should be the same as reported by this method.
estimateEncodedSize() - Method in class io.kroxylicious.proxy.frame.OpaqueFrame
eventLoopExecutor(EventLoop) - Static method in class io.kroxylicious.proxy.internal.NettyFilterDispatchExecutor
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class io.kroxylicious.proxy.internal.admin.RoutingHttpServer
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class io.kroxylicious.proxy.internal.KafkaProxyBackendHandler: Netty callback indicating that an exception reached it.
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class io.kroxylicious.proxy.internal.KafkaProxyFrontendHandler: Handles an exception in downstream/client pipeline by notifying KafkaProxyFrontendHandler.clientConnectionStateMachine of the issue.
execute(Runnable) - Method in class io.kroxylicious.proxy.internal.NettyFilterDispatchExecutor
expireAfterAccess() - Method in record class io.kroxylicious.proxy.config.CacheConfiguration: Returns the value of the expireAfterAccess record component.
expireAfterWrite() - Method in record class io.kroxylicious.proxy.config.CacheConfiguration: Returns the value of the expireAfterWrite record component.
ExpireDelegationTokenRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ExpireDelegationTokenRequestFilter.
ExpireDelegationTokenRequestFilterInvoker(ExpireDelegationTokenRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ExpireDelegationTokenRequestFilterInvoker
ExpireDelegationTokenResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ExpireDelegationTokenResponseFilter.
ExpireDelegationTokenResponseFilterInvoker(ExpireDelegationTokenResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ExpireDelegationTokenResponseFilterInvoker
extractor() - Method in record class io.kroxylicious.proxy.internal.subject.PrincipalAdder: Returns the value of the extractor record component.

F

factory() - Method in record class io.kroxylicious.proxy.internal.subject.PrincipalAdder: Returns the value of the factory record component.
Failed(Throwable) - Constructor for record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Failed: Creates an instance of a Failed record class.
Feature - Enum Class in io.kroxylicious.proxy.internal.config: Configuration Features related to how we load configuration.
Features - Class in io.kroxylicious.proxy.internal.config: Represents the entire set of proxy features.
Features.FeaturesBuilder - Class in io.kroxylicious.proxy.internal.config
FeaturesBuilder() - Constructor for class io.kroxylicious.proxy.internal.config.Features.FeaturesBuilder
FetchRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for FetchRequestFilter.
FetchRequestFilterInvoker(FetchRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.FetchRequestFilterInvoker
FetchResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for FetchResponseFilter.
FetchResponseFilterInvoker(FetchResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.FetchResponseFilterInvoker
FetchSnapshotRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for FetchSnapshotRequestFilter.
FetchSnapshotRequestFilterInvoker(FetchSnapshotRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.FetchSnapshotRequestFilterInvoker
FetchSnapshotResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for FetchSnapshotResponseFilter.
FetchSnapshotResponseFilterInvoker(FetchSnapshotResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.FetchSnapshotResponseFilterInvoker
filter() - Method in record class io.kroxylicious.proxy.internal.filter.FilterAndInvoker: Returns the value of the filter record component.
filter() - Method in record class io.kroxylicious.proxy.internal.filter.RequestFilterInvoker: Returns the value of the filter record component.
filter() - Method in record class io.kroxylicious.proxy.internal.filter.ResponseFilterInvoker: Returns the value of the filter record component.
FilterAndInvoker - Record Class in io.kroxylicious.proxy.internal.filter: A Filter and it's respective invoker
FilterAndInvoker(String, Filter, FilterInvoker) - Constructor for record class io.kroxylicious.proxy.internal.filter.FilterAndInvoker: A Filter and it's respective invoker
filterChainFactory() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel: Returns this VC's filter chain factory.
FilterChainFactory - Class in io.kroxylicious.proxy.bootstrap: Builds per-connection filter instances for a single virtual cluster's filter chain.
FilterChainFactory(PluginFactoryRegistry, List<NamedFilterDefinition>) - Constructor for class io.kroxylicious.proxy.bootstrap.FilterChainFactory
filterCipherSuites(Iterable<String>, List<String>, Set<String>) - Method in class io.kroxylicious.proxy.model.DenyCipherSuiteFilter
filterDefinitions() - Method in record class io.kroxylicious.proxy.config.Configuration: Returns the value of the filterDefinitions record component.
filterDispatchExecutor() - Method in class io.kroxylicious.proxy.internal.filter.NettyFilterContext
FilterHandler - Class in io.kroxylicious.proxy.internal: A ChannelInboundHandler (for handling requests from downstream) that applies a single Filter.
FilterHandler(FilterAndInvoker, long, String, Channel, ClientConnectionStateMachine) - Constructor for class io.kroxylicious.proxy.internal.FilterHandler
FilterInvoker - Interface in io.kroxylicious.proxy.internal.filter: The FilterInvoker connects Kroxylicious with the concrete implementation of a Filter.
FilterInvokers - Class in io.kroxylicious.proxy.internal.filter: Factory for FilterInvokers.
filterName() - Method in record class io.kroxylicious.proxy.internal.filter.FilterAndInvoker: Returns the value of the filterName record component.
FilterResultBuilderImpl<H,R> - Class in io.kroxylicious.proxy.internal.filter
FilterResultBuilderImpl() - Constructor for class io.kroxylicious.proxy.internal.filter.FilterResultBuilderImpl
filters() - Method in record class io.kroxylicious.proxy.config.RouteDefinition: Returns the value of the filters record component.
filters() - Method in record class io.kroxylicious.proxy.config.VirtualCluster: Returns the value of the filters record component.
filters() - Method in record class io.kroxylicious.proxy.internal.routing.RouteDescriptor: Returns the value of the filters record component.
FindCoordinatorRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for FindCoordinatorRequestFilter.
FindCoordinatorRequestFilterInvoker(FindCoordinatorRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.FindCoordinatorRequestFilterInvoker
FindCoordinatorResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for FindCoordinatorResponseFilter.
FindCoordinatorResponseFilterInvoker(FindCoordinatorResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.FindCoordinatorResponseFilterInvoker
forClient() - Method in class io.kroxylicious.proxy.internal.tls.NettyKeyProvider
forFilters(List<FilterAndInvoker>) - Static method in interface io.kroxylicious.proxy.internal.codec.DecodePredicate
forServer() - Method in class io.kroxylicious.proxy.internal.tls.NettyKeyProvider
forVirtualCluster(PluginFactoryRegistry, VirtualCluster, Map<String, RouterDefinition>) - Static method in class io.kroxylicious.proxy.bootstrap.RouterChainFactory: Creates a RouterChainFactory for a single virtual cluster.
forward(H, ApiMessage) - Method in class io.kroxylicious.proxy.internal.filter.FilterResultBuilderImpl
forwardToNode(int, String, Object) - Method in class io.kroxylicious.proxy.internal.ClientConnectionStateMachine: Forward a message to the backend broker identified by the virtual node ID.
forwardToRoute(String, Object) - Method in class io.kroxylicious.proxy.internal.ClientConnectionStateMachine: Forward a message to the backend connection for the named route.
Frame - Interface in io.kroxylicious.proxy.frame: A frame in the Kafka protocol, which may or may not be fully decoded.
FRAME_SIZE_LENGTH - Static variable in interface io.kroxylicious.proxy.frame.Frame: Number of bytes required for storing the frame length.
FrameOversizedException - Exception Class in io.kroxylicious.proxy.internal.codec
FrameOversizedException(int, int) - Constructor for exception class io.kroxylicious.proxy.internal.codec.FrameOversizedException
from() - Method in record class io.kroxylicious.proxy.internal.subject.PrincipalAdderConf: Returns the value of the from record component.
from(HAProxyMessage) - Static method in record class io.kroxylicious.proxy.internal.net.HaProxyContext: Creates an HaProxyContext from a Netty HAProxyMessage.
FROM_STATE_LABEL - Static variable in class io.kroxylicious.proxy.internal.util.Metrics
fromJson(Optional<Integer>, Optional<Duration>, Optional<Duration>, Optional<Duration>, Optional<Duration>, Optional<Integer>) - Static method in record class io.kroxylicious.proxy.config.NettySettings: Jackson factory that also accepts the deprecated shutdownQuietPeriodSeconds integer field, mapping it to shutdownQuietPeriod with a warning.
fromResource(String) - Static method in interface io.kroxylicious.proxy.VersionInfo: Loads version information from the supplied classpath resource.
fromVirtual(int) - Method in record class io.kroxylicious.proxy.internal.routing.BijectiveNodeIdMapping
fromVirtual(int) - Method in record class io.kroxylicious.proxy.internal.routing.IdentityNodeIdMapping
fromVirtual(int) - Method in interface io.kroxylicious.proxy.internal.routing.NodeIdMapping: Translates a virtual node ID back to its route and target-cluster node ID.
fromVirtual(String, int) - Method in record class io.kroxylicious.proxy.internal.routing.BijectiveNodeIdMapping
fromVirtual(String, int) - Method in record class io.kroxylicious.proxy.internal.routing.IdentityNodeIdMapping
fromVirtual(String, int) - Method in interface io.kroxylicious.proxy.internal.routing.NodeIdMapping: Translates a virtual node ID back to its target-cluster node ID, given the route.

G

gateways() - Method in record class io.kroxylicious.proxy.config.VirtualCluster: Returns the value of the gateways record component.
gateways() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel
getAdvertisedBrokerAddress(int) - Method in interface io.kroxylicious.proxy.internal.net.EndpointGateway: Advertised address of broker with the given node id, (advertised hostname and advertised port).
getAdvertisedBrokerAddress(int) - Method in class io.kroxylicious.proxy.model.VirtualClusterModel.VirtualClusterGatewayModel
getAdvertisedBrokerAddress(int) - Method in interface io.kroxylicious.proxy.service.NodeIdentificationStrategy: Advertised address of broker with the given node id, (advertised hostname and advertised port).
getAdvertisedBrokerAddressPattern() - Method in class io.kroxylicious.proxy.config.PortIdentifiesNodeIdentificationStrategy
getAdvertisedBrokerAddressPattern() - Method in class io.kroxylicious.proxy.config.SniHostIdentifiesNodeIdentificationStrategy
getAdvertisedPort() - Method in class io.kroxylicious.proxy.config.SniHostIdentifiesNodeIdentificationStrategy
getBindAddress() - Method in interface io.kroxylicious.proxy.internal.net.EndpointGateway: Bind address to be used for network binds.
getBindAddress() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel.VirtualClusterGatewayModel
getBindAddress() - Method in interface io.kroxylicious.proxy.service.NodeIdentificationStrategy: Gets the bind address used when binding socket.
getBindingAddress() - Method in class io.kroxylicious.proxy.internal.net.NetworkBindRequest
getBootstrapAddress() - Method in class io.kroxylicious.proxy.config.PortIdentifiesNodeIdentificationStrategy
getBootstrapAddress() - Method in class io.kroxylicious.proxy.config.SniHostIdentifiesNodeIdentificationStrategy
getBootstrapAddressPattern() - Method in class io.kroxylicious.proxy.config.SniHostIdentifiesNodeIdentificationStrategy
getBootstrapPort() - Method in class io.kroxylicious.proxy.config.SniHostIdentifiesNodeIdentificationStrategy
getBrokerAddress(int) - Method in interface io.kroxylicious.proxy.internal.net.EndpointGateway: Broker address for given nodeId.
getBrokerAddress(int) - Method in class io.kroxylicious.proxy.model.VirtualClusterModel.VirtualClusterGatewayModel
getBrokerAddress(int) - Method in interface io.kroxylicious.proxy.service.NodeIdentificationStrategy: Address of broker with the given node id, (advertised hostname and bind port).
getBrokerCorrelation(int) - Method in class io.kroxylicious.proxy.internal.codec.CorrelationManager: Find (and remove) the Correlation for an incoming response from the broker
getBrokerIdFromBrokerAddress(HostPort) - Method in interface io.kroxylicious.proxy.internal.net.EndpointGateway: Generates the node id implied by the given broker address (advertised hostname and bind port).
getBrokerIdFromBrokerAddress(HostPort) - Method in class io.kroxylicious.proxy.model.VirtualClusterModel.VirtualClusterGatewayModel
getBrokerIdFromBrokerAddress(HostPort) - Method in interface io.kroxylicious.proxy.service.NodeIdentificationStrategy: Generates the node id implied by the given broker address (advertised hostname and bind port).
getClusterBootstrapAddress() - Method in interface io.kroxylicious.proxy.internal.net.EndpointGateway: Bootstrap address.
getClusterBootstrapAddress() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel.VirtualClusterGatewayModel
getClusterBootstrapAddress() - Method in interface io.kroxylicious.proxy.service.NodeIdentificationStrategy: Address of the cluster's bootstrap address.
getClusterName() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel
getDownstreamSslContext() - Method in interface io.kroxylicious.proxy.internal.net.EndpointGateway
getDownstreamSslContext() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel.VirtualClusterGatewayModel
getEffectiveBindAddress() - Method in record class io.kroxylicious.proxy.config.admin.ManagementConfiguration: Gets the effective bind address for management taking into account defaults.
getEffectivePort() - Method in record class io.kroxylicious.proxy.config.admin.ManagementConfiguration: Gets the effective port for management taking into account defaults.
getExclusivePorts() - Method in interface io.kroxylicious.proxy.internal.net.EndpointGateway
getExclusivePorts() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel.VirtualClusterGatewayModel
getExclusivePorts() - Method in interface io.kroxylicious.proxy.service.NodeIdentificationStrategy: Set of ports number that this provider requires exclusive use.
getFilters() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel
getFuture() - Method in class io.kroxylicious.proxy.internal.net.NetworkBindingOperation: The future that signals the completion of the network binding operation.
getFuture() - Method in class io.kroxylicious.proxy.internal.net.NetworkBindRequest
getFuture() - Method in class io.kroxylicious.proxy.internal.net.NetworkUnbindRequest
getMaxFrameSizeBytes() - Method in exception class io.kroxylicious.proxy.internal.codec.FrameOversizedException
getMechanism() - Method in class io.kroxylicious.proxy.config.PluginConfigTypeIdResolver
getMicrometer() - Method in record class io.kroxylicious.proxy.config.Configuration
getNodeIdRanges() - Method in class io.kroxylicious.proxy.config.PortIdentifiesNodeIdentificationStrategy
getNodeStartPort() - Method in class io.kroxylicious.proxy.config.PortIdentifiesNodeIdentificationStrategy
getPauseThreshold() - Method in record class io.kroxylicious.proxy.micrometer.PauseDetectorHook.PauseDetectorHookConfig
getReceivedFrameSizeBytes() - Method in exception class io.kroxylicious.proxy.internal.codec.FrameOversizedException
getSharedPorts() - Method in interface io.kroxylicious.proxy.internal.net.EndpointGateway
getSharedPorts() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel.VirtualClusterGatewayModel
getSharedPorts() - Method in interface io.kroxylicious.proxy.service.NodeIdentificationStrategy: Set of ports number that this provider can share with another provider.
getSleepInterval() - Method in record class io.kroxylicious.proxy.micrometer.PauseDetectorHook.PauseDetectorHookConfig
getStrategy() - Method in interface io.kroxylicious.proxy.bootstrap.BootstrapSelectionStrategy
getStrategy() - Method in class io.kroxylicious.proxy.bootstrap.RandomBootstrapSelectionStrategy
getStrategy() - Method in class io.kroxylicious.proxy.bootstrap.RoundRobinBootstrapSelectionStrategy
getSupplier() - Method in class io.kroxylicious.proxy.bootstrap.TlsCredentialSupplierManager: Returns the shared ServerTlsCredentialSupplier instance, or null if no factory was configured.
GetTelemetrySubscriptionsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for GetTelemetrySubscriptionsRequestFilter.
GetTelemetrySubscriptionsRequestFilterInvoker(GetTelemetrySubscriptionsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.GetTelemetrySubscriptionsRequestFilterInvoker
GetTelemetrySubscriptionsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for GetTelemetrySubscriptionsResponseFilter.
GetTelemetrySubscriptionsResponseFilterInvoker(GetTelemetrySubscriptionsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.GetTelemetrySubscriptionsResponseFilterInvoker
getTls() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel.VirtualClusterGatewayModel
getTopicNameCacheFilter() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel
getUpstreamClusterForRoute(String) - Method in class io.kroxylicious.proxy.model.VirtualClusterModel: Returns the UpstreamClusterModel for a specific route, or null if the route does not target an upstream cluster (e.g. it targets a nested router).
Guarantees - Search tag in interface io.kroxylicious.proxy.internal.filter.FilterInvoker: Section

H

HandleNothingFilterInvoker - Record Class in io.kroxylicious.proxy.internal.filter
HandleNothingFilterInvoker() - Constructor for record class io.kroxylicious.proxy.internal.filter.HandleNothingFilterInvoker: Creates an instance of a HandleNothingFilterInvoker record class.
handleNothingInvoker() - Static method in class io.kroxylicious.proxy.internal.filter.FilterInvokers: An invoker that does not handle any requests or responses
handlerAdded(ChannelHandlerContext) - Method in class io.kroxylicious.proxy.internal.FilterHandler
handlerAdded(ChannelHandlerContext) - Method in class io.kroxylicious.proxy.internal.routing.RouterDispatchHandler
handlerRemoved(ChannelHandlerContext) - Method in class io.kroxylicious.proxy.internal.routing.RouterDispatchHandler
haProxyContext() - Method in class io.kroxylicious.proxy.internal.KafkaSession
HaProxyContext - Record Class in io.kroxylicious.proxy.internal.net: Immutable snapshot of a decoded PROXY protocol header.
HaProxyContext(String, String, int, int, Map<String, byte[]>) - Constructor for record class io.kroxylicious.proxy.internal.net.HaProxyContext: Compact constructor that deep-copies and wraps the TLV map to ensure immutability.
HaProxyMessageHandler - Class in io.kroxylicious.proxy.internal: A channel handler that intercepts HAProxyMessage objects emitted by Netty's HAProxyMessageDecoder and stores the extracted context in the KafkaSession.
HaProxyMessageHandler(KafkaSession) - Constructor for class io.kroxylicious.proxy.internal.HaProxyMessageHandler
HaProxyProtocolDetectionHandler - Class in io.kroxylicious.proxy.internal: Uses HAProxyMessageDecoder.detectProtocol(ByteBuf) on the first bytes of a connection to decide whether to install the PROXY protocol decoder.
HaProxyProtocolDetectionHandler(ProxyProtocolMode, KafkaSession) - Constructor for class io.kroxylicious.proxy.internal.HaProxyProtocolDetectionHandler
hasErrors() - Method in interface io.kroxylicious.proxy.reload.ReconfigureResult: Convenience predicate equivalent to !errors().isEmpty().
hashCode() - Method in record class io.kroxylicious.proxy.config.admin.EndpointsConfiguration: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.admin.ManagementConfiguration: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.admin.PrometheusMetricsConfig: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.CacheConfiguration: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.ClusterDefinition: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.Configuration: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.MicrometerDefinition: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.NamedFilterDefinition: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.NamedRange: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.NettySettings: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.NetworkDefinition: Returns a hash code value for this object.
hashCode() - Method in class io.kroxylicious.proxy.config.PortIdentifiesNodeIdentificationStrategy
hashCode() - Method in record class io.kroxylicious.proxy.config.ProxyProtocolConfig: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.Range: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.RouteDefinition: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.RouterDefinition: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.RouteTarget: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.ServiceBasedPluginFactoryRegistry.ProviderAndConfigType: Returns a hash code value for this object.
hashCode() - Method in class io.kroxylicious.proxy.config.SniHostIdentifiesNodeIdentificationStrategy
hashCode() - Method in record class io.kroxylicious.proxy.config.TargetCluster: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.TransportSubjectBuilderConfig: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.VirtualCluster: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.config.VirtualClusterGateway: Returns a hash code value for this object.
hashCode() - Method in class io.kroxylicious.proxy.internal.codec.CorrelationManager.Correlation
hashCode() - Method in class io.kroxylicious.proxy.internal.config.Features
hashCode() - Method in record class io.kroxylicious.proxy.internal.filter.FilterAndInvoker: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.filter.HandleNothingFilterInvoker: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.filter.RequestFilterInvoker: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.filter.RequestResponseInvoker: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.filter.ResponseFilterInvoker: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.filter.SafeInvoker: Returns a hash code value for this object.
hashCode() - Method in class io.kroxylicious.proxy.internal.KafkaSession
hashCode() - Method in record class io.kroxylicious.proxy.internal.net.BootstrapEndpointBinding: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.net.BrokerEndpointBinding: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.net.Endpoint: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.net.HaProxyContext: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.net.MetadataDiscoveryBrokerEndpointBinding: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.routing.BijectiveNodeIdMapping: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.routing.DirectRouting: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.routing.DynamicRouting: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.routing.IdentityNodeIdMapping: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.routing.NodeIdMapping.RouteAndNode: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.routing.RouteDescriptor: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.routing.UpstreamClusterModel: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.subject.DefaultSaslSubjectBuilderService.Config: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.subject.DefaultTransportSubjectBuilderService.Config: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.subject.Map: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.subject.PrincipalAdder: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.subject.PrincipalAdderConf: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.subject.Rule: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.tls.TlsCredentialsImpl: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.util.VirtualClusterNode: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Draining: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Failed: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Initializing: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Serving: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Stopped: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.micrometer.CommonTagsHook.CommonTagsHookConfig: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.micrometer.PauseDetectorHook.PauseDetectorHookConfig: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.micrometer.StandardBindersHook.StandardBindersHookConfig: Returns a hash code value for this object.
hashCode() - Method in record class io.kroxylicious.proxy.reload.ReconfigureError: Returns a hash code value for this object.
hashCode() - Method in class io.kroxylicious.proxy.service.HostPort
hasResponse() - Method in class io.kroxylicious.proxy.frame.DecodedRequestFrame
hasResponse() - Method in class io.kroxylicious.proxy.frame.OpaqueRequestFrame
hasResponse() - Method in interface io.kroxylicious.proxy.frame.RequestFrame: Whether the Kafka Client expects a response to this request
header - Variable in class io.kroxylicious.proxy.frame.DecodedFrame
header() - Method in class io.kroxylicious.proxy.frame.DecodedFrame
headerVersion() - Method in class io.kroxylicious.proxy.frame.DecodedFrame
headerVersion() - Method in class io.kroxylicious.proxy.frame.DecodedRequestFrame
headerVersion() - Method in class io.kroxylicious.proxy.frame.DecodedResponseFrame
HeartbeatRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for HeartbeatRequestFilter.
HeartbeatRequestFilterInvoker(HeartbeatRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.HeartbeatRequestFilterInvoker
HeartbeatResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for HeartbeatResponseFilter.
HeartbeatResponseFilterInvoker(HeartbeatResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.HeartbeatResponseFilterInvoker
host() - Method in class io.kroxylicious.proxy.service.HostPort: host
HostPort - Class in io.kroxylicious.proxy.service: Represents a host port pair.
HostPort(String, int) - Constructor for class io.kroxylicious.proxy.service.HostPort: Creates a host port.
HTTPS_HOSTNAME_VERIFICATION - Static variable in class io.kroxylicious.proxy.internal.tls.NettyTrustProvider
humanReadableIdentifier() - Method in record class io.kroxylicious.proxy.reload.ReconfigureError: Returns the value of the humanReadableIdentifier record component.
humanReadableIdentifiers() - Method in exception class io.kroxylicious.proxy.reload.StaticConfigurationChangedException: Returns the best-effort human-readable identifiers of the static configuration sections that differ between the running and submitted configurations and that the proxy declined to reconcile.

I

id() - Method in record class io.kroxylicious.proxy.config.RouteDefinition: Returns the value of the id record component.
id() - Method in record class io.kroxylicious.proxy.internal.routing.RouteDescriptor: Returns the value of the id record component.
IdentityMappingRule - Class in io.kroxylicious.proxy.internal.subject
IdentityMappingRule() - Constructor for class io.kroxylicious.proxy.internal.subject.IdentityMappingRule
IdentityNodeIdMapping - Record Class in io.kroxylicious.proxy.internal.routing: Identity node ID mapping for single-route configurations.
IdentityNodeIdMapping(String) - Constructor for record class io.kroxylicious.proxy.internal.routing.IdentityNodeIdMapping: Creates an instance of a IdentityNodeIdMapping record class.
idFromValue(Object) - Method in class io.kroxylicious.proxy.config.PluginConfigTypeIdResolver
idFromValueAndType(Object, Class<?>) - Method in class io.kroxylicious.proxy.config.PluginConfigTypeIdResolver
IDLE_TIMEOUT - Enum constant in enum class io.kroxylicious.proxy.internal.ClientConnectionStateMachine.DisconnectCause: Connection closed due to exceeding idle timeout
IllegalConfigurationException - Exception Class in io.kroxylicious.proxy.config: Signals that the configuration is syntactically/semantically correct but illegal by some policy.
IllegalConfigurationException(String) - Constructor for exception class io.kroxylicious.proxy.config.IllegalConfigurationException
implementsAnySpecificRequestFilterInterface(Filter) - Static method in class io.kroxylicious.proxy.internal.filter.SpecificFilterArrayInvoker: Check if a Filter implements any of the Specific Request Filter interfaces
implementsAnySpecificResponseFilterInterface(Filter) - Static method in class io.kroxylicious.proxy.internal.filter.SpecificFilterArrayInvoker: Check if a Filter implements any of the Specific Response Filter interfaces
IncrementalAlterConfigsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for IncrementalAlterConfigsRequestFilter.
IncrementalAlterConfigsRequestFilterInvoker(IncrementalAlterConfigsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.IncrementalAlterConfigsRequestFilterInvoker
IncrementalAlterConfigsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for IncrementalAlterConfigsResponseFilter.
IncrementalAlterConfigsResponseFilterInvoker(IncrementalAlterConfigsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.IncrementalAlterConfigsResponseFilterInvoker
init(JavaType) - Method in class io.kroxylicious.proxy.config.PluginConfigTypeIdResolver
initChannel(Channel) - Method in class io.kroxylicious.proxy.internal.KafkaProxyInitializer
initChannel(SocketChannel) - Method in class io.kroxylicious.proxy.internal.admin.ManagementInitializer
initialCapacity() - Method in class io.kroxylicious.proxy.internal.util.ByteBufOutputStream
initializationFailed(String, Throwable) - Method in class io.kroxylicious.proxy.internal.VirtualClusterRegistry: Signals that the named virtual cluster failed to initialize.
initializationFailed(Throwable) - Method in class io.kroxylicious.proxy.internal.VirtualClusterLifecycle: Transitions from VirtualClusterLifecycleState.Initializing to VirtualClusterLifecycleState.Failed, recording the cause.
initializationSucceeded() - Method in class io.kroxylicious.proxy.internal.VirtualClusterLifecycle: Transitions from VirtualClusterLifecycleState.Initializing to VirtualClusterLifecycleState.Serving.
initializationSucceeded(String) - Method in class io.kroxylicious.proxy.internal.VirtualClusterRegistry: Signals that the named virtual cluster initialized successfully.
initialize(DefaultSaslSubjectBuilderService.Config) - Method in class io.kroxylicious.proxy.internal.subject.DefaultSaslSubjectBuilderService
initialize(DefaultTransportSubjectBuilderService.Config) - Method in class io.kroxylicious.proxy.internal.subject.DefaultTransportSubjectBuilderService
InitializeShareGroupStateRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for InitializeShareGroupStateRequestFilter.
InitializeShareGroupStateRequestFilterInvoker(InitializeShareGroupStateRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.InitializeShareGroupStateRequestFilterInvoker
InitializeShareGroupStateResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for InitializeShareGroupStateResponseFilter.
InitializeShareGroupStateResponseFilterInvoker(InitializeShareGroupStateResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.InitializeShareGroupStateResponseFilterInvoker
Initializing() - Constructor for record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Initializing: Creates an instance of a Initializing record class.
InitProducerIdRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for InitProducerIdRequestFilter.
InitProducerIdRequestFilterInvoker(InitProducerIdRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.InitProducerIdRequestFilterInvoker
InitProducerIdResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for InitProducerIdResponseFilter.
InitProducerIdResponseFilterInvoker(InitProducerIdResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.InitProducerIdResponseFilterInvoker
inRange(int) - Method in class io.kroxylicious.proxy.internal.CorrelationIdAllocator
INSTANCE - Static variable in record class io.kroxylicious.proxy.internal.filter.HandleNothingFilterInvoker
INSTANCE - Static variable in class io.kroxylicious.proxy.internal.util.StableKroxyliciousLinkGenerator
InternalRequestFrame - Class in io.kroxylicious.proxy.internal
InternalRequestFrame(short, int, boolean, Filter, CompletableFuture<?>, RequestHeaderData, B) - Constructor for class io.kroxylicious.proxy.internal.InternalRequestFrame
InternalResponseFrame - Class in io.kroxylicious.proxy.internal
InternalResponseFrame(Filter, short, int, ResponseHeaderData, B, CompletableFuture<?>) - Constructor for class io.kroxylicious.proxy.internal.InternalResponseFrame
invokeAll(Collection<? extends Callable<T>>) - Method in class io.kroxylicious.proxy.internal.NettyFilterDispatchExecutor
invokeAll(Collection<? extends Callable<T>>, long, TimeUnit) - Method in class io.kroxylicious.proxy.internal.NettyFilterDispatchExecutor
invokeAny(Collection<? extends Callable<T>>) - Method in class io.kroxylicious.proxy.internal.NettyFilterDispatchExecutor
invokeAny(Collection<? extends Callable<T>>, long, TimeUnit) - Method in class io.kroxylicious.proxy.internal.NettyFilterDispatchExecutor
invoker() - Method in record class io.kroxylicious.proxy.internal.filter.FilterAndInvoker: Returns the value of the invoker record component.
invoker() - Method in record class io.kroxylicious.proxy.internal.filter.SafeInvoker: Returns the value of the invoker record component.
io.kroxylicious.proxy - package io.kroxylicious.proxy
io.kroxylicious.proxy.bootstrap - package io.kroxylicious.proxy.bootstrap
io.kroxylicious.proxy.config - package io.kroxylicious.proxy.config
io.kroxylicious.proxy.config.admin - package io.kroxylicious.proxy.config.admin
io.kroxylicious.proxy.frame - package io.kroxylicious.proxy.frame
io.kroxylicious.proxy.internal - package io.kroxylicious.proxy.internal: io.kroxylicious.proxy.internal contains Kroxylicious internal code implementing Proxying functionality using Netty.
io.kroxylicious.proxy.internal.admin - package io.kroxylicious.proxy.internal.admin
io.kroxylicious.proxy.internal.codec - package io.kroxylicious.proxy.internal.codec
io.kroxylicious.proxy.internal.config - package io.kroxylicious.proxy.internal.config
io.kroxylicious.proxy.internal.filter - package io.kroxylicious.proxy.internal.filter
io.kroxylicious.proxy.internal.filter.impl - package io.kroxylicious.proxy.internal.filter.impl: Internal Filter implementations.
io.kroxylicious.proxy.internal.metrics - package io.kroxylicious.proxy.internal.metrics
io.kroxylicious.proxy.internal.net - package io.kroxylicious.proxy.internal.net
io.kroxylicious.proxy.internal.reload - package io.kroxylicious.proxy.internal.reload
io.kroxylicious.proxy.internal.routing - package io.kroxylicious.proxy.internal.routing
io.kroxylicious.proxy.internal.subject - package io.kroxylicious.proxy.internal.subject
io.kroxylicious.proxy.internal.tls - package io.kroxylicious.proxy.internal.tls
io.kroxylicious.proxy.internal.util - package io.kroxylicious.proxy.internal.util
io.kroxylicious.proxy.micrometer - package io.kroxylicious.proxy.micrometer
io.kroxylicious.proxy.model - package io.kroxylicious.proxy.model
io.kroxylicious.proxy.reload - package io.kroxylicious.proxy.reload
io.kroxylicious.proxy.service - package io.kroxylicious.proxy.service
IP_ADDRESS - Enum constant in enum class io.kroxylicious.proxy.internal.subject.TlsCertificateExtractor.Asn1SanNameType
isConfigured() - Method in class io.kroxylicious.proxy.bootstrap.TlsCredentialSupplierManager: Returns true if a TLS credential supplier factory is configured.
isDecoded() - Method in class io.kroxylicious.proxy.frame.BareSaslRequest
isDecoded() - Method in class io.kroxylicious.proxy.frame.BareSaslResponse
isDecoded() - Method in class io.kroxylicious.proxy.frame.DecodedFrame
isDecoded() - Method in interface io.kroxylicious.proxy.frame.Frame: true if this frame is decoded, false otherwise
isDecoded() - Method in class io.kroxylicious.proxy.frame.OpaqueFrame
isDistinctFrom(NamedRange) - Method in record class io.kroxylicious.proxy.config.NamedRange: Return true if this range does not overlap with other range.
isDistinctFrom(Range) - Method in record class io.kroxylicious.proxy.config.Range: Return true if this range does not overlap with other range.
isDrop() - Method in class io.kroxylicious.proxy.internal.filter.FilterResultBuilderImpl
isEnabled(Feature) - Method in class io.kroxylicious.proxy.internal.config.Features
isInFilterDispatchThread() - Method in class io.kroxylicious.proxy.internal.NettyFilterDispatchExecutor
isLogFrames() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel
isLogNetwork() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel
isRecipient(Filter) - Method in class io.kroxylicious.proxy.internal.InternalResponseFrame
isRoutingCorrelationId(int) - Static method in class io.kroxylicious.proxy.internal.CorrelationIdSpace
isShutdown() - Method in class io.kroxylicious.proxy.internal.NettyFilterDispatchExecutor
isTerminated() - Method in class io.kroxylicious.proxy.internal.NettyFilterDispatchExecutor
isUseIoUring() - Method in record class io.kroxylicious.proxy.config.Configuration
isUseTls() - Method in interface io.kroxylicious.proxy.internal.net.EndpointGateway: true if this listener uses TLS.
isUseTls() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel.VirtualClusterGatewayModel

J

JoinGroupRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for JoinGroupRequestFilter.
JoinGroupRequestFilterInvoker(JoinGroupRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.JoinGroupRequestFilterInvoker
JoinGroupResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for JoinGroupResponseFilter.
JoinGroupResponseFilterInvoker(JoinGroupResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.JoinGroupResponseFilterInvoker

K

KafkaMessageListener - Interface in io.kroxylicious.proxy.internal.codec: Callback invoked by the KafkaMessageEncoder and KafkaMessageDecoder on encode or decode of each message.
KafkaProxy - Class in io.kroxylicious.proxy
KafkaProxy(PluginFactoryRegistry, Configuration, Features) - Constructor for class io.kroxylicious.proxy.KafkaProxy
KafkaProxyBackendHandler - Search tag in package io.kroxylicious.proxy.internal: Section
KafkaProxyBackendHandler - Class in io.kroxylicious.proxy.internal
KafkaProxyExceptionMapper - Class in io.kroxylicious.proxy.internal: In the operation of the proxy there are various exceptions which are "anticipated" but not necessarily handled directly.
KafkaProxyFrontendHandler - Search tag in package io.kroxylicious.proxy.internal: Section
KafkaProxyFrontendHandler - Class in io.kroxylicious.proxy.internal
KafkaProxyInitializer - Search tag in package io.kroxylicious.proxy.internal: Section
KafkaProxyInitializer - Class in io.kroxylicious.proxy.internal
KafkaProxyInitializer(PluginFactoryRegistry, boolean, EndpointBindingResolver, EndpointReconciler, ProxyProtocolMode, ApiVersionsServiceImpl, Optional<NettySettings>, VirtualClusterRegistry) - Constructor for class io.kroxylicious.proxy.internal.KafkaProxyInitializer
KafkaRequestDecoder - Class in io.kroxylicious.proxy.internal.codec
KafkaRequestDecoder(DecodePredicate, int, ApiVersionsServiceImpl, KafkaMessageListener) - Constructor for class io.kroxylicious.proxy.internal.codec.KafkaRequestDecoder
KafkaRequestEncoder - Class in io.kroxylicious.proxy.internal.codec
KafkaRequestEncoder(CorrelationManager, KafkaMessageListener) - Constructor for class io.kroxylicious.proxy.internal.codec.KafkaRequestEncoder
KafkaResponseDecoder - Class in io.kroxylicious.proxy.internal.codec
KafkaResponseDecoder(CorrelationManager, int, KafkaMessageListener) - Constructor for class io.kroxylicious.proxy.internal.codec.KafkaResponseDecoder
KafkaResponseEncoder - Class in io.kroxylicious.proxy.internal.codec
KafkaResponseEncoder(KafkaMessageListener) - Constructor for class io.kroxylicious.proxy.internal.codec.KafkaResponseEncoder
kafkaSession() - Method in class io.kroxylicious.proxy.internal.ClientConnectionStateMachine
KafkaSession - Class in io.kroxylicious.proxy.internal
KafkaSession(KafkaSessionState) - Constructor for class io.kroxylicious.proxy.internal.KafkaSession
KafkaSessionState - Enum Class in io.kroxylicious.proxy.internal: Describes the possible states of a Kafka session as viewed from the proxy Generally we expect a Kafka Session to transition through one of the following sequences.

L

label() - Method in enum class io.kroxylicious.proxy.internal.ClientConnectionStateMachine.DisconnectCause
latestVersion(ApiKeys) - Method in class io.kroxylicious.proxy.internal.ApiVersionsServiceImpl
LEARN_TOPIC_NAMES - Enum constant in enum class io.kroxylicious.proxy.internal.util.RequestHeaderTagger.Tag
LeaveGroupRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for LeaveGroupRequestFilter.
LeaveGroupRequestFilterInvoker(LeaveGroupRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.LeaveGroupRequestFilterInvoker
LeaveGroupResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for LeaveGroupResponseFilter.
LeaveGroupResponseFilterInvoker(LeaveGroupResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.LeaveGroupResponseFilterInvoker
length - Variable in class io.kroxylicious.proxy.frame.OpaqueFrame
LENGTH - Static variable in class io.kroxylicious.proxy.internal.codec.KafkaRequestEncoder
Lifecycle - Search tag in class io.kroxylicious.proxy.model.VirtualClusterModel: Section
LifecycleException - Exception Class in io.kroxylicious.proxy: An exception thrown during a lifecycle transition such as startup or shutdown of the proxy.
LifecycleException(String) - Constructor for exception class io.kroxylicious.proxy.LifecycleException
LifecycleException(String, Throwable) - Constructor for exception class io.kroxylicious.proxy.LifecycleException
lifecycleFor(String) - Method in class io.kroxylicious.proxy.internal.VirtualClusterRegistry: Returns the lifecycle for the given virtual cluster name.
limit() - Method in class io.kroxylicious.proxy.internal.util.ByteBufOutputStream
ListConfigResourcesRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ListConfigResourcesRequestFilter.
ListConfigResourcesRequestFilterInvoker(ListConfigResourcesRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ListConfigResourcesRequestFilterInvoker
ListConfigResourcesResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ListConfigResourcesResponseFilter.
ListConfigResourcesResponseFilterInvoker(ListConfigResourcesResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ListConfigResourcesResponseFilterInvoker
ListGroupsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ListGroupsRequestFilter.
ListGroupsRequestFilterInvoker(ListGroupsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ListGroupsRequestFilterInvoker
ListGroupsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ListGroupsResponseFilter.
ListGroupsResponseFilterInvoker(ListGroupsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ListGroupsResponseFilterInvoker
ListOffsetsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ListOffsetsRequestFilter.
ListOffsetsRequestFilterInvoker(ListOffsetsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ListOffsetsRequestFilterInvoker
ListOffsetsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ListOffsetsResponseFilter.
ListOffsetsResponseFilterInvoker(ListOffsetsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ListOffsetsResponseFilterInvoker
ListPartitionReassignmentsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ListPartitionReassignmentsRequestFilter.
ListPartitionReassignmentsRequestFilterInvoker(ListPartitionReassignmentsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ListPartitionReassignmentsRequestFilterInvoker
ListPartitionReassignmentsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ListPartitionReassignmentsResponseFilter.
ListPartitionReassignmentsResponseFilterInvoker(ListPartitionReassignmentsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ListPartitionReassignmentsResponseFilterInvoker
ListTransactionsRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ListTransactionsRequestFilter.
ListTransactionsRequestFilterInvoker(ListTransactionsRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ListTransactionsRequestFilterInvoker
ListTransactionsResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ListTransactionsResponseFilter.
ListTransactionsResponseFilterInvoker(ListTransactionsResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ListTransactionsResponseFilterInvoker
localPortFor(Endpoint) - Method in class io.kroxylicious.proxy.internal.net.EndpointRegistry
log() - Method in class io.kroxylicious.proxy.internal.codec.KafkaRequestDecoder
log() - Method in class io.kroxylicious.proxy.internal.codec.KafkaRequestEncoder
log() - Method in class io.kroxylicious.proxy.internal.codec.KafkaResponseDecoder
log() - Method in class io.kroxylicious.proxy.internal.codec.KafkaResponseEncoder
logFrames() - Method in record class io.kroxylicious.proxy.config.VirtualCluster: Returns the value of the logFrames record component.
logNetwork() - Method in record class io.kroxylicious.proxy.config.VirtualCluster: Returns the value of the logNetwork record component.
logVirtualClusterSummary() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel

M

management() - Method in record class io.kroxylicious.proxy.config.Configuration: Returns the value of the management record component.
management() - Method in record class io.kroxylicious.proxy.config.NetworkDefinition: Returns the value of the management record component.
ManagementConfiguration - Record Class in io.kroxylicious.proxy.config.admin: Management configuration.
ManagementConfiguration(String, Integer, EndpointsConfiguration) - Constructor for record class io.kroxylicious.proxy.config.admin.ManagementConfiguration: Creates an instance of a ManagementConfiguration record class.
ManagementInitializer - Class in io.kroxylicious.proxy.internal.admin
ManagementInitializer(MeterRegistries, ManagementConfiguration) - Constructor for class io.kroxylicious.proxy.internal.admin.ManagementInitializer
map() - Method in record class io.kroxylicious.proxy.internal.subject.PrincipalAdderConf: Returns the value of the map record component.
Map - Record Class in io.kroxylicious.proxy.internal.subject
Map(String, String) - Constructor for record class io.kroxylicious.proxy.internal.subject.Map: Creates an instance of a Map record class.
mapper - Static variable in class io.kroxylicious.proxy.config.AbstractDefinitionBuilder
maxSize() - Method in record class io.kroxylicious.proxy.config.CacheConfiguration: Returns the value of the maxSize record component.
maybePrometheus() - Method in record class io.kroxylicious.proxy.config.admin.EndpointsConfiguration
maybePrometheusMeterRegistry() - Method in class io.kroxylicious.proxy.internal.MeterRegistries: Offers up a prometheus registry if available.
maybeWarning(boolean) - Method in enum class io.kroxylicious.proxy.internal.config.Feature: At proxy initialisation time, this method will be invoked to give the feature an opportunity to log any disclaimers.
mechanismName() - Method in class io.kroxylicious.proxy.internal.ClientSubjectManager
MemoryRecordsHelper - Class in io.kroxylicious.proxy.internal.util: This introduces additional factory builder methods for MemoryRecords that accepts ByteBufOutputStream
METADATA_API_VER_WITH_TOPIC_ID_SUPPORT - Static variable in class io.kroxylicious.proxy.internal.TopicNameRetriever
MetadataDiscoveryBrokerEndpointBinding - Record Class in io.kroxylicious.proxy.internal.net: A bootstrap binding which can only be used for metadata discovery.
MetadataDiscoveryBrokerEndpointBinding(EndpointGateway, Integer) - Constructor for record class io.kroxylicious.proxy.internal.net.MetadataDiscoveryBrokerEndpointBinding: Creates an instance of a MetadataDiscoveryBrokerEndpointBinding record class.
MetadataRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for MetadataRequestFilter.
MetadataRequestFilterInvoker(MetadataRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.MetadataRequestFilterInvoker
MetadataResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for MetadataResponseFilter.
MetadataResponseFilterInvoker(MetadataResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.MetadataResponseFilterInvoker
MeterRegistries - Class in io.kroxylicious.proxy.internal
MeterRegistries(PluginFactoryRegistry, List<MicrometerDefinition>) - Constructor for class io.kroxylicious.proxy.internal.MeterRegistries
MetricEmittingKafkaMessageListener - Class in io.kroxylicious.proxy.internal.metrics: A kafka message listener that emits message count and message size metrics.
MetricEmittingKafkaMessageListener(Meter.MeterProvider<Counter>, Meter.MeterProvider<DistributionSummary>) - Constructor for class io.kroxylicious.proxy.internal.metrics.MetricEmittingKafkaMessageListener
Metrics - Class in io.kroxylicious.proxy.internal.util
micrometer() - Method in record class io.kroxylicious.proxy.config.Configuration: Returns the value of the micrometer record component.
MicrometerConfigurationHook - Interface in io.kroxylicious.proxy.micrometer
MicrometerConfigurationHookService<T> - Interface in io.kroxylicious.proxy.micrometer: Service to build a MicrometerConfigurationHook for a configuration.
MicrometerDefinition - Record Class in io.kroxylicious.proxy.config
MicrometerDefinition(String, Object) - Constructor for record class io.kroxylicious.proxy.config.MicrometerDefinition: Creates an instance of a MicrometerDefinition record class.
mode() - Method in record class io.kroxylicious.proxy.config.ProxyProtocolConfig: Returns the value of the mode record component.
modelFor(String) - Method in class io.kroxylicious.proxy.internal.VirtualClusterRegistry: Returns the model for the given virtual cluster name.

N

name() - Method in record class io.kroxylicious.proxy.config.ClusterDefinition: Returns the value of the name record component.
name() - Method in record class io.kroxylicious.proxy.config.NamedFilterDefinition: Returns the value of the name record component.
name() - Method in record class io.kroxylicious.proxy.config.NamedRange: Returns the value of the name record component.
name() - Method in record class io.kroxylicious.proxy.config.RouteDefinition: Returns the value of the name record component.
name() - Method in record class io.kroxylicious.proxy.config.RouterDefinition: Returns the value of the name record component.
name() - Method in record class io.kroxylicious.proxy.config.VirtualCluster: Returns the value of the name record component.
name() - Method in record class io.kroxylicious.proxy.config.VirtualClusterGateway: Returns the value of the name record component.
name() - Method in interface io.kroxylicious.proxy.internal.net.EndpointGateway: Get the gateways name
name() - Method in record class io.kroxylicious.proxy.internal.routing.RouteDescriptor: Returns the value of the name record component.
name() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel.VirtualClusterGatewayModel
NamedFilterDefinition - Record Class in io.kroxylicious.proxy.config: A named filter definition
NamedFilterDefinition(String, String, Object) - Constructor for record class io.kroxylicious.proxy.config.NamedFilterDefinition: Creates an instance of a NamedFilterDefinition record class.
NamedRange - Record Class in io.kroxylicious.proxy.config: Represents the inclusive set of integers between two integer endpoints.
NamedRange(String, int, int) - Constructor for record class io.kroxylicious.proxy.config.NamedRange: Constructs a Range
namedTargetCluster() - Method in record class io.kroxylicious.proxy.config.VirtualCluster
NettyFilterContext - Class in io.kroxylicious.proxy.internal.filter
NettyFilterContext(EventLoop, PluginFactoryRegistry) - Constructor for class io.kroxylicious.proxy.internal.filter.NettyFilterContext
NettyFilterDispatchExecutor - Class in io.kroxylicious.proxy.internal
NettyKeyProvider - Class in io.kroxylicious.proxy.internal.tls
NettyKeyProvider(KeyProvider) - Constructor for class io.kroxylicious.proxy.internal.tls.NettyKeyProvider
NettySettings - Record Class in io.kroxylicious.proxy.config
NettySettings(Optional<Integer>, Optional<Duration>, Optional<Duration>, Optional<Duration>, Optional<Duration>) - Constructor for record class io.kroxylicious.proxy.config.NettySettings: Creates an instance of a NettySettings record class.
NettyTrustProvider - Class in io.kroxylicious.proxy.internal.tls
NettyTrustProvider(TrustProvider) - Constructor for class io.kroxylicious.proxy.internal.tls.NettyTrustProvider
network() - Method in record class io.kroxylicious.proxy.config.Configuration: Returns the value of the network record component.
NetworkBindingOperation - Class in io.kroxylicious.proxy.internal.net: Abstract encapsulation of a network binding operation.
NetworkBindingOperation(boolean) - Constructor for class io.kroxylicious.proxy.internal.net.NetworkBindingOperation: Creates a NetworkBindingOperation with given TLS mode.
NetworkBindingOperationProcessor - Interface in io.kroxylicious.proxy.internal.net: Processes NetworkBindingOperations on a suitable ServerBootstrap.
NetworkBindRequest - Class in io.kroxylicious.proxy.internal.net: Request for a network endpoint to be bound.
NetworkBindRequest(CompletableFuture<Channel>, Endpoint) - Constructor for class io.kroxylicious.proxy.internal.net.NetworkBindRequest
NetworkDefinition - Record Class in io.kroxylicious.proxy.config
NetworkDefinition(NettySettings, NettySettings) - Constructor for record class io.kroxylicious.proxy.config.NetworkDefinition: Creates an instance of a NetworkDefinition record class.
NetworkUnbindRequest - Class in io.kroxylicious.proxy.internal.net: Request for a network endpoint to be unbound.
NetworkUnbindRequest(boolean, Channel, CompletableFuture<Void>) - Constructor for class io.kroxylicious.proxy.internal.net.NetworkUnbindRequest
NO_CHANNEL_BINDINGS_MESSAGE - Static variable in class io.kroxylicious.proxy.internal.net.EndpointRegistry
NODE_ID_LABEL - Static variable in class io.kroxylicious.proxy.internal.util.Metrics
NODE_ID_TRANSLATION_APIS - Static variable in class io.kroxylicious.proxy.internal.routing.RouterDispatchHandler: API keys whose responses carry node IDs that must be translated to virtual node IDs.
nodeId() - Method in record class io.kroxylicious.proxy.internal.net.BootstrapEndpointBinding
nodeId() - Method in record class io.kroxylicious.proxy.internal.net.BrokerEndpointBinding: Returns the value of the nodeId record component.
nodeId() - Method in interface io.kroxylicious.proxy.internal.net.EndpointBinding: Returns the broker node id associated with this endpoint.
nodeId() - Method in record class io.kroxylicious.proxy.internal.net.MetadataDiscoveryBrokerEndpointBinding: Returns the value of the nodeId record component.
nodeId() - Method in interface io.kroxylicious.proxy.internal.net.NodeSpecificEndpointBinding
nodeId() - Method in record class io.kroxylicious.proxy.internal.util.VirtualClusterNode: Returns the value of the nodeId record component.
NodeIdentificationStrategy - Interface in io.kroxylicious.proxy.service: This is the Strategy for how we expose a virtual kafka cluster on the network.
NodeIdentificationStrategyFactory - Interface in io.kroxylicious.proxy.config
nodeIdMapping() - Method in record class io.kroxylicious.proxy.internal.routing.DynamicRouting: Returns the value of the nodeIdMapping record component.
NodeIdMapping - Interface in io.kroxylicious.proxy.internal.routing: Maps between target-cluster node IDs and the virtual node IDs presented to clients.
NodeIdMapping.RouteAndNode - Record Class in io.kroxylicious.proxy.internal.routing: A route name and target-cluster node ID pair.
NodeSpecificEndpointBinding - Interface in io.kroxylicious.proxy.internal.net
NOT_AUTHENTICATED - Enum constant in enum class io.kroxylicious.proxy.internal.KafkaSessionState: The proxy has established TCP connections to both client and broker.
NoUpstreamClusterForRouteException - Exception Class in io.kroxylicious.proxy.internal.routing
NoUpstreamClusterForRouteException(String) - Constructor for exception class io.kroxylicious.proxy.internal.routing.NoUpstreamClusterForRouteException

O

of(Collection<ReconfigureError>) - Static method in interface io.kroxylicious.proxy.reload.ReconfigureResult: Returns a ReconfigureResult backed by an immutable copy of the given errors.
OffsetCommitRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for OffsetCommitRequestFilter.
OffsetCommitRequestFilterInvoker(OffsetCommitRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.OffsetCommitRequestFilterInvoker
OffsetCommitResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for OffsetCommitResponseFilter.
OffsetCommitResponseFilterInvoker(OffsetCommitResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.OffsetCommitResponseFilterInvoker
OffsetDeleteRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for OffsetDeleteRequestFilter.
OffsetDeleteRequestFilterInvoker(OffsetDeleteRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.OffsetDeleteRequestFilterInvoker
OffsetDeleteResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for OffsetDeleteResponseFilter.
OffsetDeleteResponseFilterInvoker(OffsetDeleteResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.OffsetDeleteResponseFilterInvoker
OffsetFetchRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for OffsetFetchRequestFilter.
OffsetFetchRequestFilterInvoker(OffsetFetchRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.OffsetFetchRequestFilterInvoker
OffsetFetchResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for OffsetFetchResponseFilter.
OffsetFetchResponseFilterInvoker(OffsetFetchResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.OffsetFetchResponseFilterInvoker
OffsetForLeaderEpochRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for OffsetForLeaderEpochRequestFilter.
OffsetForLeaderEpochRequestFilterInvoker(OffsetForLeaderEpochRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.OffsetForLeaderEpochRequestFilterInvoker
OffsetForLeaderEpochResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for OffsetForLeaderEpochResponseFilter.
OffsetForLeaderEpochResponseFilterInvoker(OffsetForLeaderEpochResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.OffsetForLeaderEpochResponseFilterInvoker
onApiVersionsRequest(short, RequestHeaderData, ApiVersionsRequestData, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.impl.ApiVersionsDowngradeFilter
onApiVersionsResponse(short, ResponseHeaderData, ApiVersionsResponseData, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.impl.ApiVersionsIntersectFilter
onClientFilterChainComplete(Object) - Method in class io.kroxylicious.proxy.internal.ClientConnectionStateMachine: A message has emerged from the filter chain and is ready to be forwarded to the upstream node.
onClientTlsHandshakeSuccess(SSLSession) - Method in class io.kroxylicious.proxy.internal.ClientConnectionStateMachine
onClientUnwritable() - Method in class io.kroxylicious.proxy.internal.ClientConnectionStateMachine: Notify the state machine when the client applies back pressure.
onClientWritable() - Method in class io.kroxylicious.proxy.internal.ClientConnectionStateMachine: Notify the state machine when the client stops applying back pressure
onDescribeClusterResponse(short, ResponseHeaderData, DescribeClusterResponseData, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.impl.BrokerAddressFilter
onFetchResponse(short, ResponseHeaderData, FetchResponseData, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.impl.BrokerAddressFilter
onFindCoordinatorResponse(short, ResponseHeaderData, FindCoordinatorResponseData, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.impl.BrokerAddressFilter
onMessage(Frame, int) - Method in interface io.kroxylicious.proxy.internal.codec.KafkaMessageListener: Called each time a kafka message is encoded or decoded.
onMessage(Frame, int) - Method in class io.kroxylicious.proxy.internal.metrics.MetricEmittingKafkaMessageListener
onMetadataRequest(short, RequestHeaderData, MetadataRequestData, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.impl.TopicNameCacheFilter
onMetadataResponse(short, ResponseHeaderData, MetadataResponseData, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.impl.BrokerAddressFilter
onMetadataResponse(short, ResponseHeaderData, MetadataResponseData, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.impl.TopicNameCacheFilter
onProduceResponse(short, ResponseHeaderData, ProduceResponseData, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.impl.BrokerAddressFilter
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.AddOffsetsToTxnRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.AddPartitionsToTxnRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.AddRaftVoterRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.AllocateProducerIdsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.AlterClientQuotasRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.AlterConfigsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.AlterPartitionReassignmentsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.AlterPartitionRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.AlterReplicaLogDirsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.AlterShareGroupOffsetsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.AlterUserScramCredentialsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ApiVersionsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.AssignReplicasToDirsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.BeginQuorumEpochRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.BrokerHeartbeatRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.BrokerRegistrationRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ConsumerGroupDescribeRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ConsumerGroupHeartbeatRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ControllerRegistrationRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.CreateAclsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.CreateDelegationTokenRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.CreatePartitionsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.CreateTopicsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DeleteAclsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DeleteGroupsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DeleteRecordsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DeleteShareGroupOffsetsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DeleteShareGroupStateRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DeleteTopicsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeAclsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeClientQuotasRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeClusterRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeConfigsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeDelegationTokenRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeGroupsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeLogDirsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeProducersRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeQuorumRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeShareGroupOffsetsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeTopicPartitionsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeTransactionsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeUserScramCredentialsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ElectLeadersRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.EndQuorumEpochRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.EndTxnRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.EnvelopeRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ExpireDelegationTokenRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.FetchRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.FetchSnapshotRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in interface io.kroxylicious.proxy.internal.filter.FilterInvoker: Handle deserialized request data.
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.FindCoordinatorRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.GetTelemetrySubscriptionsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in record class io.kroxylicious.proxy.internal.filter.HandleNothingFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.HeartbeatRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.impl.EagerMetadataLearner
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.IncrementalAlterConfigsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.InitializeShareGroupStateRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.InitProducerIdRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.JoinGroupRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.LeaveGroupRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ListConfigResourcesRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ListGroupsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ListOffsetsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ListPartitionReassignmentsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ListTransactionsRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.MetadataRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.OffsetCommitRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.OffsetDeleteRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.OffsetFetchRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.OffsetForLeaderEpochRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ProduceRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.PushTelemetryRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ReadShareGroupStateRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ReadShareGroupStateSummaryRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.RemoveRaftVoterRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.RenewDelegationTokenRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in record class io.kroxylicious.proxy.internal.filter.RequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in record class io.kroxylicious.proxy.internal.filter.RequestResponseInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in record class io.kroxylicious.proxy.internal.filter.SafeInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.SaslAuthenticateRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.SaslHandshakeRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ShareAcknowledgeRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ShareFetchRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ShareGroupDescribeRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ShareGroupHeartbeatRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.SpecificFilterArrayInvoker: Apply the filter to the given header and body using the given filterContext.
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.StreamsGroupDescribeRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.StreamsGroupHeartbeatRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.SyncGroupRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.TxnOffsetCommitRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.UnregisterBrokerRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.UpdateFeaturesRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.UpdateRaftVoterRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.VoteRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.WriteShareGroupStateRequestFilterInvoker
onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.WriteTxnMarkersRequestFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.AddOffsetsToTxnResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.AddPartitionsToTxnResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.AddRaftVoterResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.AllocateProducerIdsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.AlterClientQuotasResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.AlterConfigsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.AlterPartitionReassignmentsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.AlterPartitionResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.AlterReplicaLogDirsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.AlterShareGroupOffsetsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.AlterUserScramCredentialsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ApiVersionsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.AssignReplicasToDirsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.BeginQuorumEpochResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.BrokerHeartbeatResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.BrokerRegistrationResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ConsumerGroupDescribeResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ConsumerGroupHeartbeatResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ControllerRegistrationResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.CreateAclsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.CreateDelegationTokenResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.CreatePartitionsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.CreateTopicsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DeleteAclsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DeleteGroupsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DeleteRecordsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DeleteShareGroupOffsetsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DeleteShareGroupStateResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DeleteTopicsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeAclsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeClientQuotasResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeClusterResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeConfigsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeDelegationTokenResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeGroupsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeLogDirsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeProducersResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeQuorumResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeShareGroupOffsetsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeTopicPartitionsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeTransactionsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.DescribeUserScramCredentialsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ElectLeadersResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.EndQuorumEpochResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.EndTxnResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.EnvelopeResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ExpireDelegationTokenResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.FetchResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.FetchSnapshotResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in interface io.kroxylicious.proxy.internal.filter.FilterInvoker: Handle deserialized response data.
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.FindCoordinatorResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.GetTelemetrySubscriptionsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in record class io.kroxylicious.proxy.internal.filter.HandleNothingFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.HeartbeatResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.IncrementalAlterConfigsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.InitializeShareGroupStateResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.InitProducerIdResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.JoinGroupResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.LeaveGroupResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ListConfigResourcesResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ListGroupsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ListOffsetsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ListPartitionReassignmentsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ListTransactionsResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.MetadataResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.OffsetCommitResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.OffsetDeleteResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.OffsetFetchResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.OffsetForLeaderEpochResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ProduceResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.PushTelemetryResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ReadShareGroupStateResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ReadShareGroupStateSummaryResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.RemoveRaftVoterResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.RenewDelegationTokenResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in record class io.kroxylicious.proxy.internal.filter.RequestResponseInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in record class io.kroxylicious.proxy.internal.filter.ResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in record class io.kroxylicious.proxy.internal.filter.SafeInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.SaslAuthenticateResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.SaslHandshakeResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ShareAcknowledgeResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ShareFetchResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ShareGroupDescribeResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.ShareGroupHeartbeatResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.SpecificFilterArrayInvoker: Apply the filter to the given header and body using the given filterContext.
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.StreamsGroupDescribeResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.StreamsGroupHeartbeatResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.SyncGroupResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.TxnOffsetCommitResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.UnregisterBrokerResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.UpdateFeaturesResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.UpdateRaftVoterResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.VoteResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.WriteShareGroupStateResponseFilterInvoker
onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.WriteTxnMarkersResponseFilterInvoker
onRoutedRequestComplete() - Method in class io.kroxylicious.proxy.internal.ClientConnectionStateMachine: Signals that a dynamically-routed client request has been fully handled.
onSessionAuthenticated() - Method in class io.kroxylicious.proxy.internal.KafkaProxyFrontendHandler
onSessionSaslAuthenticated() - Method in class io.kroxylicious.proxy.internal.ClientConnectionStateMachine
onSessionTransportAuthenticated() - Method in class io.kroxylicious.proxy.internal.ClientConnectionStateMachine
onShareAcknowledgeResponse(short, ResponseHeaderData, ShareAcknowledgeResponseData, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.impl.BrokerAddressFilter
onShareFetchResponse(short, ResponseHeaderData, ShareFetchResponseData, FilterContext) - Method in class io.kroxylicious.proxy.internal.filter.impl.BrokerAddressFilter
OpaqueFrame - Class in io.kroxylicious.proxy.frame: A frame in the Kafka protocol which has not been decoded.
OpaqueRequestFrame - Class in io.kroxylicious.proxy.frame: Used to represent Kafka requests that the proxy does not need to decode.
OpaqueRequestFrame(ByteBuf, short, short, int, boolean, int, boolean) - Constructor for class io.kroxylicious.proxy.frame.OpaqueRequestFrame: Creates an opaque request.
OpaqueResponseFrame - Class in io.kroxylicious.proxy.frame: Used to represent Kafka responses that the proxy does not need to decode.
OpaqueResponseFrame(short, short, ByteBuf, int, int) - Constructor for class io.kroxylicious.proxy.frame.OpaqueResponseFrame: Creates an opaque response.
OPERATION_LABEL - Static variable in class io.kroxylicious.proxy.internal.util.Metrics
OS_ASSIGNED_PORT - Static variable in class io.kroxylicious.proxy.internal.net.EndpointRegistry: Sentinel port value meaning "let the OS assign a free port at bind time".
OUTCOME_LABEL - Static variable in class io.kroxylicious.proxy.internal.util.Metrics
Owned resources - Search tag in class io.kroxylicious.proxy.model.VirtualClusterModel: Section

P

parse(String) - Static method in class io.kroxylicious.proxy.service.HostPort: Parses a host port pair from a string representation.
parseConfiguration(InputStream) - Method in class io.kroxylicious.proxy.config.ConfigParser
parseConfiguration(String) - Method in class io.kroxylicious.proxy.config.ConfigParser
PATH - Static variable in class io.kroxylicious.proxy.internal.admin.PrometheusMetricsEndpoint
PauseDetectorHook - Class in io.kroxylicious.proxy.micrometer
PauseDetectorHook() - Constructor for class io.kroxylicious.proxy.micrometer.PauseDetectorHook
PauseDetectorHook.PauseDetectorHookConfig - Record Class in io.kroxylicious.proxy.micrometer
PauseDetectorHookConfig(Long, Long) - Constructor for record class io.kroxylicious.proxy.micrometer.PauseDetectorHook.PauseDetectorHookConfig: Creates an instance of a PauseDetectorHookConfig record class.
pauseThresholdMs() - Method in record class io.kroxylicious.proxy.micrometer.PauseDetectorHook.PauseDetectorHookConfig: Returns the value of the pauseThresholdMs record component.
performBindingOperation(ServerBootstrap, ExecutorService) - Method in class io.kroxylicious.proxy.internal.net.NetworkBindingOperation: Performs the binding operation.
performBindingOperation(ServerBootstrap, ExecutorService) - Method in class io.kroxylicious.proxy.internal.net.NetworkBindRequest
performBindingOperation(ServerBootstrap, ExecutorService) - Method in class io.kroxylicious.proxy.internal.net.NetworkUnbindRequest
PluginConfigTypeIdResolver - Class in io.kroxylicious.proxy.config
PluginDiscoveryException - Exception Class in io.kroxylicious.proxy.config: Problems with plugin interfaces implementations.
PluginDiscoveryException(String) - Constructor for exception class io.kroxylicious.proxy.config.PluginDiscoveryException
pluginFactory(Class) - Method in interface io.kroxylicious.proxy.config.PluginFactoryRegistry: Resolve a plugin interface type to a factory for that type of plugin
pluginFactory(Class) - Method in class io.kroxylicious.proxy.config.ServiceBasedPluginFactoryRegistry
pluginFactory(Class<T>) - Method in class io.kroxylicious.proxy.config.ConfigParser
PluginFactory - Interface in io.kroxylicious.proxy.config: A PluginFactory is able to resolve references to a plugin implementation (i.e. a name) to that implementation.
PluginFactoryRegistry - Interface in io.kroxylicious.proxy.config
pluginImplementationNames(Class) - Method in class io.kroxylicious.proxy.internal.filter.NettyFilterContext
pluginInstance(Class, String) - Method in class io.kroxylicious.proxy.internal.filter.NettyFilterContext
pluginInstance(String) - Method in interface io.kroxylicious.proxy.config.PluginFactory: Resolves a plugin reference to a plugin implementation.
port() - Method in record class io.kroxylicious.proxy.config.admin.ManagementConfiguration: Returns the value of the port record component.
port() - Method in record class io.kroxylicious.proxy.internal.net.Endpoint: Returns the value of the port record component.
port() - Method in class io.kroxylicious.proxy.internal.net.NetworkBindingOperation: The port associated with the binding operation.
port() - Method in class io.kroxylicious.proxy.internal.net.NetworkBindRequest
port() - Method in class io.kroxylicious.proxy.internal.net.NetworkUnbindRequest
port() - Method in class io.kroxylicious.proxy.service.HostPort: port
PortConflictDetector - Class in io.kroxylicious.proxy.internal: Detects potential for port conflicts arising between virtual cluster configurations.
PortConflictDetector() - Constructor for class io.kroxylicious.proxy.internal.PortConflictDetector
portIdentifiesNode() - Method in record class io.kroxylicious.proxy.config.VirtualClusterGateway: Returns the value of the portIdentifiesNode record component.
PortIdentifiesNodeIdentificationStrategy - Class in io.kroxylicious.proxy.config: A NodeIdentificationStrategy implementation that uses a separate port per broker endpoint and that is aware of distinct ranges of nodeIds present in the target cluster.
PortIdentifiesNodeIdentificationStrategy(HostPort, String, Integer, List<NamedRange>) - Constructor for class io.kroxylicious.proxy.config.PortIdentifiesNodeIdentificationStrategy
position() - Method in class io.kroxylicious.proxy.internal.util.ByteBufOutputStream
position(int) - Method in class io.kroxylicious.proxy.internal.util.ByteBufOutputStream
PRE_SESSION_IDLE_HANDLER - Static variable in class io.kroxylicious.proxy.internal.KafkaProxyInitializer
PrincipalAdder - Record Class in io.kroxylicious.proxy.internal.subject
PrincipalAdder(Function<Object, Stream<String>>, List<MappingRule>, PrincipalFactory<?>) - Constructor for record class io.kroxylicious.proxy.internal.subject.PrincipalAdder: Creates an instance of a PrincipalAdder record class.
PrincipalAdderConf - Record Class in io.kroxylicious.proxy.internal.subject: Configuration for a principal adder, which is responsible for contributing zero or more principals to the subject.
PrincipalAdderConf(String, List<Map>, String) - Constructor for record class io.kroxylicious.proxy.internal.subject.PrincipalAdderConf: Creates an instance of a PrincipalAdderConf record class.
principalFactory() - Method in record class io.kroxylicious.proxy.internal.subject.PrincipalAdderConf: Returns the value of the principalFactory record component.
priorFailureCause() - Method in record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Stopped: Returns the value of the priorFailureCause record component.
privateKey() - Method in record class io.kroxylicious.proxy.internal.tls.TlsCredentialsImpl: Returns the value of the privateKey record component.
ProduceRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ProduceRequestFilter.
ProduceRequestFilterInvoker(ProduceRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ProduceRequestFilterInvoker
ProduceResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ProduceResponseFilter.
ProduceResponseFilterInvoker(ProduceResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ProduceResponseFilterInvoker
prometheus() - Method in record class io.kroxylicious.proxy.config.admin.EndpointsConfiguration: Returns the value of the prometheus record component.
PrometheusMetricsConfig - Record Class in io.kroxylicious.proxy.config.admin
PrometheusMetricsConfig() - Constructor for record class io.kroxylicious.proxy.config.admin.PrometheusMetricsConfig: Creates an instance of a PrometheusMetricsConfig record class.
PrometheusMetricsEndpoint - Class in io.kroxylicious.proxy.internal.admin
PrometheusMetricsEndpoint(MeterRegistries) - Constructor for class io.kroxylicious.proxy.internal.admin.PrometheusMetricsEndpoint
promise() - Method in class io.kroxylicious.proxy.internal.codec.CorrelationManager.Correlation
promise() - Method in class io.kroxylicious.proxy.internal.InternalRequestFrame
promise() - Method in class io.kroxylicious.proxy.internal.InternalResponseFrame
provider() - Method in record class io.kroxylicious.proxy.config.ServiceBasedPluginFactoryRegistry.ProviderAndConfigType: Returns the value of the provider record component.
ProviderAndConfigType(ServiceLoader.Provider<?>, Class<?>) - Constructor for record class io.kroxylicious.proxy.config.ServiceBasedPluginFactoryRegistry.ProviderAndConfigType: Creates an instance of a ProviderAndConfigType record class.
proxy() - Method in record class io.kroxylicious.proxy.config.NetworkDefinition: Returns the value of the proxy record component.
proxyProtocol() - Method in record class io.kroxylicious.proxy.config.Configuration: Returns the value of the proxyProtocol record component.
ProxyProtocolConfig - Record Class in io.kroxylicious.proxy.config: Configuration for the HaProxy PROXY protocol.
ProxyProtocolConfig(ProxyProtocolMode) - Constructor for record class io.kroxylicious.proxy.config.ProxyProtocolConfig: Creates an instance of a ProxyProtocolConfig record class.
proxyProtocolMode() - Method in record class io.kroxylicious.proxy.config.Configuration
ProxyProtocolMode - Enum Class in io.kroxylicious.proxy.config: Controls how Kroxylicious handles HaProxy PROXY protocol headers on incoming connections.
proxyServerCertificate() - Method in class io.kroxylicious.proxy.internal.ClientSubjectManager
proxyToClientMessageCounterProvider(String, Integer) - Static method in class io.kroxylicious.proxy.internal.util.Metrics
proxyToClientMessageSizeDistributionProvider(String, Integer) - Static method in class io.kroxylicious.proxy.internal.util.Metrics
proxyToServerConnectionCounter(VirtualClusterNode) - Static method in class io.kroxylicious.proxy.internal.util.Metrics
proxyToServerConnectionCounter(String, Integer) - Static method in class io.kroxylicious.proxy.internal.util.Metrics
proxyToServerConnectionToken(VirtualClusterNode) - Static method in class io.kroxylicious.proxy.internal.util.Metrics
proxyToServerErrorCounter(String, Integer) - Static method in class io.kroxylicious.proxy.internal.util.Metrics
proxyToServerMessageCounterProvider(String, Integer) - Static method in class io.kroxylicious.proxy.internal.util.Metrics
proxyToServerMessageSizeDistributionProvider(String, Integer) - Static method in class io.kroxylicious.proxy.internal.util.Metrics
PushTelemetryRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for PushTelemetryRequestFilter.
PushTelemetryRequestFilterInvoker(PushTelemetryRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.PushTelemetryRequestFilterInvoker
PushTelemetryResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for PushTelemetryResponseFilter.
PushTelemetryResponseFilterInvoker(PushTelemetryResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.PushTelemetryResponseFilterInvoker
putBrokerRequest(short, short, int, boolean, Filter, CompletableFuture<?>, boolean) - Method in class io.kroxylicious.proxy.internal.codec.CorrelationManager: Allocate and return a correlation id for an outgoing request to the broker.

R

RandomBootstrapSelectionStrategy - Class in io.kroxylicious.proxy.bootstrap: BootstrapSelectionStrategy which selects a random server from the given list of servers as the bootstrap server.
RandomBootstrapSelectionStrategy() - Constructor for class io.kroxylicious.proxy.bootstrap.RandomBootstrapSelectionStrategy
Range - Record Class in io.kroxylicious.proxy.config: Represents the set of integers between two integer endpoints.
Range(int, int) - Constructor for record class io.kroxylicious.proxy.config.Range: Constructs a Range
readArray(int) - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
readArray(int) - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
readByte() - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
readByte() - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
readByteBuffer(int) - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
readByteBuffer(int) - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
readDouble() - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
readDouble() - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
readerIndex() - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
readerIndex() - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
readerIndex(int) - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
readerIndex(int) - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
readInt() - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
readInt() - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
readLong() - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
readLong() - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
ReadShareGroupStateRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ReadShareGroupStateRequestFilter.
ReadShareGroupStateRequestFilterInvoker(ReadShareGroupStateRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ReadShareGroupStateRequestFilterInvoker
ReadShareGroupStateResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ReadShareGroupStateResponseFilter.
ReadShareGroupStateResponseFilterInvoker(ReadShareGroupStateResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ReadShareGroupStateResponseFilterInvoker
ReadShareGroupStateSummaryRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ReadShareGroupStateSummaryRequestFilter.
ReadShareGroupStateSummaryRequestFilterInvoker(ReadShareGroupStateSummaryRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ReadShareGroupStateSummaryRequestFilterInvoker
ReadShareGroupStateSummaryResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ReadShareGroupStateSummaryResponseFilter.
ReadShareGroupStateSummaryResponseFilterInvoker(ReadShareGroupStateSummaryResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ReadShareGroupStateSummaryResponseFilterInvoker
readShort() - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
readShort() - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
readUnsignedVarint() - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
readUnsignedVarint() - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
readUnsignedVarint(ByteBuf) - Static method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
readVarint() - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
readVarint() - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
readVarint(ByteBuf) - Static method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
readVarlong() - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
readVarlong() - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
readVarlong(ByteBuf) - Static method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl: Read a long stored in variable-length format using zig-zag decoding from Google Protocol Buffers.
recipient() - Method in class io.kroxylicious.proxy.internal.codec.CorrelationManager.Correlation
recipient() - Method in class io.kroxylicious.proxy.internal.InternalRequestFrame
recipient() - Method in class io.kroxylicious.proxy.internal.InternalResponseFrame
reconcile(EndpointGateway, Map<Integer, HostPort>) - Method in interface io.kroxylicious.proxy.internal.net.EndpointReconciler: Reconciles the existing set endpoints for this virtual cluster against those required for the current set of nodes for this virtual cluster.
reconcile(EndpointGateway, Map<Integer, HostPort>) - Method in class io.kroxylicious.proxy.internal.net.EndpointRegistry: Reconciles the current set of bindings for this virtual cluster against those required by the current set of nodes.
reconfigure(Configuration) - Method in class io.kroxylicious.proxy.internal.reload.ConfigurationReloadOrchestrator: Apply newConfig to the running proxy.
reconfigure(Configuration) - Method in class io.kroxylicious.proxy.KafkaProxy: Apply the given configuration to this running proxy, restarting only the virtual clusters whose effective configuration differs from the current running state.
reconfigureClustersAffectedCounter(String, String) - Static method in class io.kroxylicious.proxy.internal.util.Metrics: Counter of per-virtual-cluster operations applied during reconfigures, tagged by operation (add, remove, modify) and outcome (success, failure).
reconfigureCounter(String) - Static method in class io.kroxylicious.proxy.internal.util.Metrics: Counter of reconfigure() invocations that got past pre-flight validation, tagged by outcome (success, partial_failure, catastrophic).
reconfigureDurationTimer() - Static method in class io.kroxylicious.proxy.internal.util.Metrics: Timer for end-to-end reconfigure duration.
ReconfigureError - Record Class in io.kroxylicious.proxy.reload: One per-component failure encountered during a KafkaProxy.reconfigure(Configuration) call.
ReconfigureError(String, Throwable) - Constructor for record class io.kroxylicious.proxy.reload.ReconfigureError: Creates an instance of a ReconfigureError record class.
ReconfigureResult - Interface in io.kroxylicious.proxy.reload: Outcome of a KafkaProxy.reconfigure(Configuration) call.
refersToSameVirtualClusterAndNode(NodeSpecificEndpointBinding) - Method in interface io.kroxylicious.proxy.internal.net.NodeSpecificEndpointBinding
registerConnection(ClientConnectionStateMachine) - Method in class io.kroxylicious.proxy.internal.VirtualClusterLifecycle
registerConnection(String, ClientConnectionStateMachine) - Method in class io.kroxylicious.proxy.internal.VirtualClusterRegistry: Attempts to register a new connection for clusterName.
registeredInstanceNames() - Method in interface io.kroxylicious.proxy.config.PluginFactory: Returns the names of the registered instances of this plugin.
registerVirtualCluster(EndpointGateway) - Method in class io.kroxylicious.proxy.internal.net.EndpointRegistry: Registers a virtual cluster with the registry.
release() - Method in class io.kroxylicious.proxy.internal.util.ActivationToken
releaseBuffer() - Method in class io.kroxylicious.proxy.frame.OpaqueFrame: Releases the underlying buffer.
remaining() - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
remaining() - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
remaining() - Method in class io.kroxylicious.proxy.internal.util.ByteBufOutputStream
remoteHost() - Method in class io.kroxylicious.proxy.internal.KafkaProxyFrontendHandler
remotePort() - Method in class io.kroxylicious.proxy.internal.KafkaProxyFrontendHandler
RemoveRaftVoterRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for RemoveRaftVoterRequestFilter.
RemoveRaftVoterRequestFilterInvoker(RemoveRaftVoterRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.RemoveRaftVoterRequestFilterInvoker
RemoveRaftVoterResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for RemoveRaftVoterResponseFilter.
RemoveRaftVoterResponseFilterInvoker(RemoveRaftVoterResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.RemoveRaftVoterResponseFilterInvoker
removeTags(RequestHeaderData) - Static method in class io.kroxylicious.proxy.internal.util.RequestHeaderTagger
removeVirtualCluster(String) - Method in class io.kroxylicious.proxy.internal.VirtualClusterRegistry: Drives an existing virtual cluster through SERVING → DRAINING → STOPPED.
RenewDelegationTokenRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for RenewDelegationTokenRequestFilter.
RenewDelegationTokenRequestFilterInvoker(RenewDelegationTokenRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.RenewDelegationTokenRequestFilterInvoker
RenewDelegationTokenResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for RenewDelegationTokenResponseFilter.
RenewDelegationTokenResponseFilterInvoker(RenewDelegationTokenResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.RenewDelegationTokenResponseFilterInvoker
replaceMatch() - Method in record class io.kroxylicious.proxy.internal.subject.Map: Returns the value of the replaceMatch record component.
replaceMatchMappingRule() - Method in record class io.kroxylicious.proxy.internal.subject.Rule: Returns the value of the replaceMatchMappingRule record component.
ReplaceMatchMappingRule - Class in io.kroxylicious.proxy.internal.subject
ReplaceMatchMappingRule(String) - Constructor for class io.kroxylicious.proxy.internal.subject.ReplaceMatchMappingRule
requestFilter() - Method in record class io.kroxylicious.proxy.internal.filter.RequestResponseInvoker: Returns the value of the requestFilter record component.
RequestFilterInvoker - Record Class in io.kroxylicious.proxy.internal.filter
RequestFilterInvoker(RequestFilter) - Constructor for record class io.kroxylicious.proxy.internal.filter.RequestFilterInvoker: Creates an instance of a RequestFilterInvoker record class.
RequestFilterResultBuilderImpl - Class in io.kroxylicious.proxy.internal.filter
RequestFilterResultBuilderImpl() - Constructor for class io.kroxylicious.proxy.internal.filter.RequestFilterResultBuilderImpl
RequestFrame - Interface in io.kroxylicious.proxy.frame
RequestHeaderTagger - Class in io.kroxylicious.proxy.internal.util: Utility for tagging message headers with internal tags.
RequestHeaderTagger() - Constructor for class io.kroxylicious.proxy.internal.util.RequestHeaderTagger
RequestHeaderTagger.Tag - Enum Class in io.kroxylicious.proxy.internal.util
RequestResponseInvoker - Record Class in io.kroxylicious.proxy.internal.filter
RequestResponseInvoker(RequestFilter, ResponseFilter) - Constructor for record class io.kroxylicious.proxy.internal.filter.RequestResponseInvoker: Creates an instance of a RequestResponseInvoker record class.
REQUIRED - Enum constant in enum class io.kroxylicious.proxy.config.ProxyProtocolMode: Every incoming connection must begin with a valid PROXY protocol header (v1 or v2).
requirePositive(long, String) - Static method in class io.kroxylicious.proxy.internal.util.Assertions
requiresServerNameIndication() - Method in interface io.kroxylicious.proxy.internal.net.EndpointGateway: Indicates if the provider requires that connections utilise the Server Name Indication (SNI) extension to TLS.
requiresServerNameIndication() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel.VirtualClusterGatewayModel
requiresServerNameIndication() - Method in interface io.kroxylicious.proxy.service.NodeIdentificationStrategy: Indicates if the provider requires that connections utilise the Server Name Indication (SNI) extension to TLS.
requiresTls() - Method in record class io.kroxylicious.proxy.internal.routing.UpstreamClusterModel
requireStrictlyPositive(long, String) - Static method in class io.kroxylicious.proxy.internal.util.Assertions
RESERVED_OUT_OF_BAND_CORRELATION_ID - Static variable in class io.kroxylicious.proxy.internal.CorrelationIdSpace
RESERVED_ROUTING_ID_RANGE_END_EXC - Static variable in class io.kroxylicious.proxy.internal.CorrelationIdSpace
RESERVED_ROUTING_ID_RANGE_START_INC - Static variable in class io.kroxylicious.proxy.internal.CorrelationIdSpace
resolve(Endpoint, String) - Method in interface io.kroxylicious.proxy.internal.net.EndpointBindingResolver: Uses channel metadata from the incoming connection to resolve a EndpointBinding.
resolve(Endpoint, String) - Method in class io.kroxylicious.proxy.internal.net.EndpointRegistry: Uses channel metadata (port, SNI name etc.) from the incoming connection to resolve a BootstrapEndpointBinding.
resolveModel(Configuration, String) - Method in class io.kroxylicious.proxy.internal.VirtualClusterRegistry: Builds a VirtualClusterModel for the named virtual cluster, dispatched onto the lifecycle thread.
resolveRouterNodeAddress(int) - Method in class io.kroxylicious.proxy.internal.routing.RouterDispatchHandler: Returns the upstream address for the given virtual node ID, as learned from the most recent internal METADATA response.
responseFilter() - Method in record class io.kroxylicious.proxy.internal.filter.RequestResponseInvoker: Returns the value of the responseFilter record component.
ResponseFilterInvoker - Record Class in io.kroxylicious.proxy.internal.filter
ResponseFilterInvoker(ResponseFilter) - Constructor for record class io.kroxylicious.proxy.internal.filter.ResponseFilterInvoker: Creates an instance of a ResponseFilterInvoker record class.
ResponseFilterResultBuilderImpl - Class in io.kroxylicious.proxy.internal.filter
ResponseFilterResultBuilderImpl() - Constructor for class io.kroxylicious.proxy.internal.filter.ResponseFilterResultBuilderImpl
responseFrame(ResponseHeaderData, ApiMessage) - Method in class io.kroxylicious.proxy.frame.DecodedRequestFrame
ResponseFrame - Interface in io.kroxylicious.proxy.frame
ResponseOrderer - Class in io.kroxylicious.proxy.internal: While processing a request from a Client, we want to enable custom Protocol Filters to decide to send a response toward the Client instead of forwarding the message on towards the upstream broker.
ResponseOrderer() - Constructor for class io.kroxylicious.proxy.internal.ResponseOrderer
responseWithBody(HttpRequest, HttpResponseStatus, String) - Static method in class io.kroxylicious.proxy.internal.admin.RoutingHttpServer
responseWithStatus(HttpRequest, HttpResponseStatus) - Static method in class io.kroxylicious.proxy.internal.admin.RoutingHttpServer
restrictUpstreamToMetadataDiscovery() - Method in interface io.kroxylicious.proxy.internal.net.EndpointBinding: If set true, the upstream target must only be used for metadata discovery.
restrictUpstreamToMetadataDiscovery() - Method in record class io.kroxylicious.proxy.internal.net.MetadataDiscoveryBrokerEndpointBinding
RFC822 - Enum constant in enum class io.kroxylicious.proxy.internal.subject.TlsCertificateExtractor.Asn1SanNameType
RoundRobinBootstrapSelectionStrategy - Class in io.kroxylicious.proxy.bootstrap: BootstrapSelectionStrategy that selects a server from the given list of servers as the bootstrap server in a round-robin fashion.
RoundRobinBootstrapSelectionStrategy() - Constructor for class io.kroxylicious.proxy.bootstrap.RoundRobinBootstrapSelectionStrategy
route() - Method in record class io.kroxylicious.proxy.internal.routing.NodeIdMapping.RouteAndNode: Returns the value of the route record component.
RouteAndNode(String, int) - Constructor for record class io.kroxylicious.proxy.internal.routing.NodeIdMapping.RouteAndNode: Creates an instance of a RouteAndNode record class.
routeClusterModels() - Method in record class io.kroxylicious.proxy.internal.routing.DynamicRouting: Returns the value of the routeClusterModels record component.
RouteDefinition - Record Class in io.kroxylicious.proxy.config: A route within a router definition.
RouteDefinition(String, int, List<String>, RouteTarget) - Constructor for record class io.kroxylicious.proxy.config.RouteDefinition: Creates an instance of a RouteDefinition record class.
RouteDescriptor - Record Class in io.kroxylicious.proxy.internal.routing: Runtime representation of a resolved route within a router.
RouteDescriptor(String, int, TargetCluster, String, List<NamedFilterDefinition>) - Constructor for record class io.kroxylicious.proxy.internal.routing.RouteDescriptor: Creates an instance of a RouteDescriptor record class.
routeDescriptors() - Method in record class io.kroxylicious.proxy.internal.routing.DynamicRouting: Returns the value of the routeDescriptors record component.
routeIds() - Method in record class io.kroxylicious.proxy.internal.routing.BijectiveNodeIdMapping: Returns the value of the routeIds record component.
routeName() - Method in record class io.kroxylicious.proxy.internal.routing.DirectRouting: Returns the value of the routeName record component.
routeName() - Method in record class io.kroxylicious.proxy.internal.routing.IdentityNodeIdMapping: Returns the value of the routeName record component.
routeName(String) - Static method in record class io.kroxylicious.proxy.internal.routing.DirectRouting
router() - Method in record class io.kroxylicious.proxy.config.RouteDefinition
router() - Method in record class io.kroxylicious.proxy.config.RouteTarget: Returns the value of the router record component.
router() - Method in record class io.kroxylicious.proxy.config.VirtualCluster
routerChainFactory() - Method in record class io.kroxylicious.proxy.internal.routing.DynamicRouting: Returns the value of the routerChainFactory record component.
RouterChainFactory - Class in io.kroxylicious.proxy.bootstrap: Abstracts the creation of router instances, hiding the configuration required for instantiation at the point at which instances are created.
RouterChainFactory(PluginFactoryRegistry, List<VirtualCluster>, List<RouterDefinition>) - Constructor for class io.kroxylicious.proxy.bootstrap.RouterChainFactory
RouterDefinition - Record Class in io.kroxylicious.proxy.config: A named router definition referencing a RouterFactory plugin type.
RouterDefinition(String, String, Object, List<RouteDefinition>) - Constructor for record class io.kroxylicious.proxy.config.RouterDefinition: Creates an instance of a RouterDefinition record class.
routerDefinitions() - Method in record class io.kroxylicious.proxy.config.Configuration: Returns the value of the routerDefinitions record component.
RouterDispatchHandler - Class in io.kroxylicious.proxy.internal.routing: Sits at the end of the VC-level filter chain (instead of FilterChainCompletionHandler) when a virtual cluster uses a router.
RouterDispatchHandler(Router, Map<String, RouteDescriptor>, Map<ApiKeys, String>, ClientConnectionStateMachine, String, NodeIdMapping, Integer) - Constructor for class io.kroxylicious.proxy.internal.routing.RouterDispatchHandler
routerName() - Method in record class io.kroxylicious.proxy.internal.routing.DynamicRouting: Returns the value of the routerName record component.
routerName() - Method in record class io.kroxylicious.proxy.internal.routing.RouteDescriptor: Returns the value of the routerName record component.
routes() - Method in record class io.kroxylicious.proxy.config.RouterDefinition: Returns the value of the routes record component.
RouteTarget - Record Class in io.kroxylicious.proxy.config: A target for a route: exactly one of cluster or router must be specified.
RouteTarget(String, String) - Constructor for record class io.kroxylicious.proxy.config.RouteTarget: Creates an instance of a RouteTarget record class.
routing() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel
ROUTING - Enum constant in enum class io.kroxylicious.proxy.internal.config.Feature: Enables the routing API (routers, routes, and multi-cluster request dispatch).
RoutingHttpServer - Class in io.kroxylicious.proxy.internal.admin
RoutingHttpServer.RoutingHttpServerBuilder - Class in io.kroxylicious.proxy.internal.admin
RoutingHttpServerBuilder() - Constructor for class io.kroxylicious.proxy.internal.admin.RoutingHttpServer.RoutingHttpServerBuilder
RoutingModel - Interface in io.kroxylicious.proxy.internal.routing: Sealed hierarchy representing how a virtual cluster reaches its upstream Kafka cluster(s).
Rule - Record Class in io.kroxylicious.proxy.internal.subject
Rule(ReplaceMatchMappingRule, IdentityMappingRule) - Constructor for record class io.kroxylicious.proxy.internal.subject.Rule: Creates an instance of a Rule record class.
rules() - Method in record class io.kroxylicious.proxy.internal.subject.PrincipalAdder: Returns the value of the rules record component.

S

SafeInvoker - Record Class in io.kroxylicious.proxy.internal.filter: Wraps a delegate invoker so that onRequest and onResponse can be safely called even if this Invoker does not want to handle this message, in this case the message will be forwarded without the delegate doing anything with it.
SafeInvoker(FilterInvoker) - Constructor for record class io.kroxylicious.proxy.internal.filter.SafeInvoker: Creates an instance of a SafeInvoker record class.
sameAs(NamedFilterDefinition) - Method in record class io.kroxylicious.proxy.config.NamedFilterDefinition: Returns true if this definition is semantically identical to other.
sameAs(VirtualCluster) - Method in record class io.kroxylicious.proxy.config.VirtualCluster: Returns true if this cluster's deployment-time configuration is semantically identical to other's.
san(TlsCertificateExtractor.Asn1SanNameType) - Static method in interface io.kroxylicious.proxy.internal.subject.TlsCertificateExtractor
SASL_AUTHENTICATED - Enum constant in enum class io.kroxylicious.proxy.internal.KafkaSessionState: The client has been successfully authenticated using SASLS credentials (at least once).
SASL_AUTHORIZED_ID - Static variable in class io.kroxylicious.proxy.internal.subject.DefaultSaslSubjectBuilderService
SaslAuthenticateRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for SaslAuthenticateRequestFilter.
SaslAuthenticateRequestFilterInvoker(SaslAuthenticateRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.SaslAuthenticateRequestFilterInvoker
SaslAuthenticateResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for SaslAuthenticateResponseFilter.
SaslAuthenticateResponseFilterInvoker(SaslAuthenticateResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.SaslAuthenticateResponseFilterInvoker
SaslHandshakeRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for SaslHandshakeRequestFilter.
SaslHandshakeRequestFilterInvoker(SaslHandshakeRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.SaslHandshakeRequestFilterInvoker
SaslHandshakeResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for SaslHandshakeResponseFilter.
SaslHandshakeResponseFilterInvoker(SaslHandshakeResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.SaslHandshakeResponseFilterInvoker
SaslSubjectBuilderImpl - Class in io.kroxylicious.proxy.internal.subject
SaslSubjectBuilderImpl() - Constructor for class io.kroxylicious.proxy.internal.subject.SaslSubjectBuilderImpl
SaslV0RejectionHandler - Class in io.kroxylicious.proxy.internal: Short circuit respond with an error code if we encounter a SASL v0 handshake, logging a meaningful warning and closing the connection.
SaslV0RejectionHandler() - Constructor for class io.kroxylicious.proxy.internal.SaslV0RejectionHandler
schedule(Runnable, long, TimeUnit) - Method in class io.kroxylicious.proxy.internal.NettyFilterDispatchExecutor
schedule(Callable<V>, long, TimeUnit) - Method in class io.kroxylicious.proxy.internal.NettyFilterDispatchExecutor
scheduleAtFixedRate(Runnable, long, long, TimeUnit) - Method in class io.kroxylicious.proxy.internal.NettyFilterDispatchExecutor
scheduleWithFixedDelay(Runnable, long, long, TimeUnit) - Method in class io.kroxylicious.proxy.internal.NettyFilterDispatchExecutor
Scope - Search tag in class io.kroxylicious.proxy.bootstrap.FilterChainFactory: Section
selectionStrategy() - Method in record class io.kroxylicious.proxy.config.TargetCluster: Returns the value of the selectionStrategy record component.
serialize(Duration, JsonGenerator, SerializerProvider) - Method in class io.kroxylicious.proxy.config.DurationSerde.Serializer
Serializer() - Constructor for class io.kroxylicious.proxy.config.DurationSerde.Serializer
SERVER_CLOSED - Enum constant in enum class io.kroxylicious.proxy.internal.ClientConnectionStateMachine.DisconnectCause: Server (backend Kafka broker) initiated connection close
ServerTlsCredentialSupplierContextImpl - Class in io.kroxylicious.proxy.internal.tls: Runtime implementation of ServerTlsCredentialSupplierContext.
ServerTlsCredentialSupplierContextImpl(ClientTlsContext) - Constructor for class io.kroxylicious.proxy.internal.tls.ServerTlsCredentialSupplierContextImpl
serverToProxyBackpressureTimer(String, Integer) - Static method in class io.kroxylicious.proxy.internal.util.Metrics
serverToProxyMessageCounterProvider(String, Integer) - Static method in class io.kroxylicious.proxy.internal.util.Metrics
serverToProxyMessageSizeDistributionProvider(String, Integer) - Static method in class io.kroxylicious.proxy.internal.util.Metrics
ServiceBasedPluginFactoryRegistry - Class in io.kroxylicious.proxy.config: A PluginFactoryRegistry that is implemented using ServiceLoader discovery.
ServiceBasedPluginFactoryRegistry() - Constructor for class io.kroxylicious.proxy.config.ServiceBasedPluginFactoryRegistry
ServiceBasedPluginFactoryRegistry.ProviderAndConfigType - Record Class in io.kroxylicious.proxy.config
Serving() - Constructor for record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Serving: Creates an instance of a Serving record class.
sessionId() - Method in class io.kroxylicious.proxy.internal.ClientConnectionStateMachine
sessionId() - Method in class io.kroxylicious.proxy.internal.KafkaSession
setHaProxyContext(HaProxyContext) - Method in class io.kroxylicious.proxy.internal.KafkaSession: Store the HaProxy PROXY-protocol context for this session.
setRouterActive() - Method in class io.kroxylicious.proxy.internal.ClientConnectionStateMachine: Signals that a RouterDispatchHandler is active on this connection's pipeline.
setStrategy(String) - Method in interface io.kroxylicious.proxy.bootstrap.BootstrapSelectionStrategy
setUpstreamAddressResolver(Function<Integer, Optional<HostPort>>) - Method in class io.kroxylicious.proxy.internal.ClientConnectionStateMachine: Sets the resolver used by ClientConnectionStateMachine.forwardToNode(int, java.lang.String, java.lang.Object) to translate a virtual node ID to an upstream address.
ShareAcknowledgeRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ShareAcknowledgeRequestFilter.
ShareAcknowledgeRequestFilterInvoker(ShareAcknowledgeRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ShareAcknowledgeRequestFilterInvoker
ShareAcknowledgeResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ShareAcknowledgeResponseFilter.
ShareAcknowledgeResponseFilterInvoker(ShareAcknowledgeResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ShareAcknowledgeResponseFilterInvoker
ShareFetchRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ShareFetchRequestFilter.
ShareFetchRequestFilterInvoker(ShareFetchRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ShareFetchRequestFilterInvoker
ShareFetchResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ShareFetchResponseFilter.
ShareFetchResponseFilterInvoker(ShareFetchResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ShareFetchResponseFilterInvoker
ShareGroupDescribeRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ShareGroupDescribeRequestFilter.
ShareGroupDescribeRequestFilterInvoker(ShareGroupDescribeRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ShareGroupDescribeRequestFilterInvoker
ShareGroupDescribeResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ShareGroupDescribeResponseFilter.
ShareGroupDescribeResponseFilterInvoker(ShareGroupDescribeResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ShareGroupDescribeResponseFilterInvoker
ShareGroupHeartbeatRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ShareGroupHeartbeatRequestFilter.
ShareGroupHeartbeatRequestFilterInvoker(ShareGroupHeartbeatRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ShareGroupHeartbeatRequestFilterInvoker
ShareGroupHeartbeatResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for ShareGroupHeartbeatResponseFilter.
ShareGroupHeartbeatResponseFilterInvoker(ShareGroupHeartbeatResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.ShareGroupHeartbeatResponseFilterInvoker
shortCircuitResponse(ResponseHeaderData, ApiMessage) - Method in class io.kroxylicious.proxy.internal.filter.RequestFilterResultBuilderImpl
shortCircuitResponse(ApiMessage) - Method in class io.kroxylicious.proxy.internal.filter.RequestFilterResultBuilderImpl
shouldDecodeRequest(ApiKeys, short) - Method in interface io.kroxylicious.proxy.internal.codec.DecodePredicate
shouldDecodeResponse(ApiKeys, short) - Method in interface io.kroxylicious.proxy.internal.codec.DecodePredicate
shouldHandleFetchResponse(short) - Method in class io.kroxylicious.proxy.internal.filter.impl.BrokerAddressFilter
shouldHandleProduceResponse(short) - Method in class io.kroxylicious.proxy.internal.filter.impl.BrokerAddressFilter
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.AddOffsetsToTxnRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.AddPartitionsToTxnRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.AddRaftVoterRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.AllocateProducerIdsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.AlterClientQuotasRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.AlterConfigsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.AlterPartitionReassignmentsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.AlterPartitionRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.AlterReplicaLogDirsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.AlterShareGroupOffsetsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.AlterUserScramCredentialsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ApiVersionsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.AssignReplicasToDirsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.BeginQuorumEpochRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.BrokerHeartbeatRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.BrokerRegistrationRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ConsumerGroupDescribeRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ConsumerGroupHeartbeatRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ControllerRegistrationRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.CreateAclsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.CreateDelegationTokenRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.CreatePartitionsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.CreateTopicsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DeleteAclsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DeleteGroupsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DeleteRecordsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DeleteShareGroupOffsetsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DeleteShareGroupStateRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DeleteTopicsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeAclsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeClientQuotasRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeClusterRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeConfigsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeDelegationTokenRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeGroupsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeLogDirsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeProducersRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeQuorumRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeShareGroupOffsetsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeTopicPartitionsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeTransactionsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeUserScramCredentialsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ElectLeadersRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.EndQuorumEpochRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.EndTxnRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.EnvelopeRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ExpireDelegationTokenRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.FetchRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.FetchSnapshotRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in interface io.kroxylicious.proxy.internal.filter.FilterInvoker: Should this Invoker handle a request with a given api key and api version.
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.FindCoordinatorRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.GetTelemetrySubscriptionsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.HeartbeatRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.IncrementalAlterConfigsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.InitializeShareGroupStateRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.InitProducerIdRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.JoinGroupRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.LeaveGroupRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ListConfigResourcesRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ListGroupsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ListOffsetsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ListPartitionReassignmentsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ListTransactionsRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.MetadataRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.OffsetCommitRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.OffsetDeleteRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.OffsetFetchRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.OffsetForLeaderEpochRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ProduceRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.PushTelemetryRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ReadShareGroupStateRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ReadShareGroupStateSummaryRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.RemoveRaftVoterRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.RenewDelegationTokenRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in record class io.kroxylicious.proxy.internal.filter.RequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in record class io.kroxylicious.proxy.internal.filter.RequestResponseInvoker
shouldHandleRequest(ApiKeys, short) - Method in record class io.kroxylicious.proxy.internal.filter.SafeInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.SaslAuthenticateRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.SaslHandshakeRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ShareAcknowledgeRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ShareFetchRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ShareGroupDescribeRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ShareGroupHeartbeatRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.SpecificFilterArrayInvoker: Determines whether a request with the given apiKey and apiVersion should be deserialized.
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.StreamsGroupDescribeRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.StreamsGroupHeartbeatRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.SyncGroupRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.TxnOffsetCommitRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.UnregisterBrokerRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.UpdateFeaturesRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.UpdateRaftVoterRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.VoteRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.WriteShareGroupStateRequestFilterInvoker
shouldHandleRequest(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.WriteTxnMarkersRequestFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.AddOffsetsToTxnResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.AddPartitionsToTxnResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.AddRaftVoterResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.AllocateProducerIdsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.AlterClientQuotasResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.AlterConfigsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.AlterPartitionReassignmentsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.AlterPartitionResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.AlterReplicaLogDirsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.AlterShareGroupOffsetsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.AlterUserScramCredentialsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ApiVersionsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.AssignReplicasToDirsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.BeginQuorumEpochResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.BrokerHeartbeatResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.BrokerRegistrationResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ConsumerGroupDescribeResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ConsumerGroupHeartbeatResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ControllerRegistrationResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.CreateAclsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.CreateDelegationTokenResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.CreatePartitionsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.CreateTopicsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DeleteAclsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DeleteGroupsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DeleteRecordsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DeleteShareGroupOffsetsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DeleteShareGroupStateResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DeleteTopicsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeAclsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeClientQuotasResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeClusterResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeConfigsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeDelegationTokenResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeGroupsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeLogDirsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeProducersResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeQuorumResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeShareGroupOffsetsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeTopicPartitionsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeTransactionsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.DescribeUserScramCredentialsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ElectLeadersResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.EndQuorumEpochResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.EndTxnResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.EnvelopeResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ExpireDelegationTokenResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.FetchResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.FetchSnapshotResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in interface io.kroxylicious.proxy.internal.filter.FilterInvoker: Should this Invoker handle a response with a given api key and api version.
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.FindCoordinatorResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.GetTelemetrySubscriptionsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.HeartbeatResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.IncrementalAlterConfigsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.InitializeShareGroupStateResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.InitProducerIdResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.JoinGroupResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.LeaveGroupResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ListConfigResourcesResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ListGroupsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ListOffsetsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ListPartitionReassignmentsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ListTransactionsResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.MetadataResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.OffsetCommitResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.OffsetDeleteResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.OffsetFetchResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.OffsetForLeaderEpochResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ProduceResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.PushTelemetryResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ReadShareGroupStateResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ReadShareGroupStateSummaryResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.RemoveRaftVoterResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.RenewDelegationTokenResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in record class io.kroxylicious.proxy.internal.filter.RequestResponseInvoker
shouldHandleResponse(ApiKeys, short) - Method in record class io.kroxylicious.proxy.internal.filter.ResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in record class io.kroxylicious.proxy.internal.filter.SafeInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.SaslAuthenticateResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.SaslHandshakeResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ShareAcknowledgeResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ShareFetchResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ShareGroupDescribeResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.ShareGroupHeartbeatResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.SpecificFilterArrayInvoker: Determines whether a response with the given apiKey and apiVersion should be deserialized.
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.StreamsGroupDescribeResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.StreamsGroupHeartbeatResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.SyncGroupResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.TxnOffsetCommitResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.UnregisterBrokerResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.UpdateFeaturesResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.UpdateRaftVoterResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.VoteResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.WriteShareGroupStateResponseFilterInvoker
shouldHandleResponse(ApiKeys, short) - Method in class io.kroxylicious.proxy.internal.filter.WriteTxnMarkersResponseFilterInvoker
shutdown() - Method in class io.kroxylicious.proxy.internal.net.EndpointRegistry: Signals that the registry should be shut down.
shutdown() - Method in class io.kroxylicious.proxy.internal.NettyFilterDispatchExecutor
shutdown() - Method in class io.kroxylicious.proxy.KafkaProxy: Shuts down a running proxy.
shutdownAllClusters() - Method in class io.kroxylicious.proxy.internal.VirtualClusterRegistry: Transitions all virtual clusters toward draining/stopped as appropriate for shutdown.
shutdownNow() - Method in class io.kroxylicious.proxy.internal.NettyFilterDispatchExecutor
shutdownQuietPeriod() - Method in record class io.kroxylicious.proxy.config.NettySettings: Returns the value of the shutdownQuietPeriod record component.
shutdownTimeout() - Method in record class io.kroxylicious.proxy.config.NettySettings: Returns the value of the shutdownTimeout record component.
sleepIntervalMs() - Method in record class io.kroxylicious.proxy.micrometer.PauseDetectorHook.PauseDetectorHookConfig: Returns the value of the sleepIntervalMs record component.
slice() - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
sniHostIdentifiesNode() - Method in record class io.kroxylicious.proxy.config.VirtualClusterGateway: Returns the value of the sniHostIdentifiesNode record component.
SniHostIdentifiesNodeIdentificationStrategy - Class in io.kroxylicious.proxy.config: A NodeIdentificationStrategy implementation that binds to a single, shared, port for bootstrap and all brokers.
SniHostIdentifiesNodeIdentificationStrategy(String, String) - Constructor for class io.kroxylicious.proxy.config.SniHostIdentifiesNodeIdentificationStrategy
SniHostIdentifiesNodeIdentificationStrategy.UnresolvedHostException - Exception Class in io.kroxylicious.proxy.config
socketFrameMaxSizeBytes() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel
sourceAddress() - Method in record class io.kroxylicious.proxy.internal.net.HaProxyContext: Returns the value of the sourceAddress record component.
sourcePort() - Method in record class io.kroxylicious.proxy.internal.net.HaProxyContext: Returns the value of the sourcePort record component.
SpecificFilterArrayInvoker - Class in io.kroxylicious.proxy.internal.filter: Invoker for Filters that implement any number of Specific Message interfaces (for example AlterConfigsResponseFilter.
SpecificFilterArrayInvoker(Filter) - Constructor for class io.kroxylicious.proxy.internal.filter.SpecificFilterArrayInvoker
SslContextBuildException - Exception Class in io.kroxylicious.proxy.internal.tls
SslContextBuildException(String, Throwable) - Constructor for exception class io.kroxylicious.proxy.internal.tls.SslContextBuildException
SslContextBuildException(Throwable) - Constructor for exception class io.kroxylicious.proxy.internal.tls.SslContextBuildException
StableKroxyliciousLinkGenerator - Class in io.kroxylicious.proxy.internal.util
StandardBindersHook - Class in io.kroxylicious.proxy.micrometer
StandardBindersHook() - Constructor for class io.kroxylicious.proxy.micrometer.StandardBindersHook
StandardBindersHook.StandardBindersHookConfig - Record Class in io.kroxylicious.proxy.micrometer
StandardBindersHookConfig(List<String>) - Constructor for record class io.kroxylicious.proxy.micrometer.StandardBindersHook.StandardBindersHookConfig: Creates an instance of a StandardBindersHookConfig record class.
start() - Method in record class io.kroxylicious.proxy.config.NamedRange: Returns the value of the start record component.
start(ServerBootstrap, ServerBootstrap) - Method in class io.kroxylicious.proxy.internal.net.DefaultNetworkBindingOperationProcessor
start(ServerBootstrap, ServerBootstrap) - Method in interface io.kroxylicious.proxy.internal.net.NetworkBindingOperationProcessor: Starts the processor running.
startDraining() - Method in class io.kroxylicious.proxy.internal.VirtualClusterLifecycle: Transitions from VirtualClusterLifecycleState.Serving to VirtualClusterLifecycleState.Draining and initiates close on all active connections.
startInclusive() - Method in record class io.kroxylicious.proxy.config.Range: Returns the value of the startInclusive record component.
startup() - Method in class io.kroxylicious.proxy.KafkaProxy: Starts this proxy.
state() - Method in class io.kroxylicious.proxy.internal.VirtualClusterLifecycle
STATE_LABEL - Static variable in class io.kroxylicious.proxy.internal.util.Metrics
StaticConfigurationChangedException - Exception Class in io.kroxylicious.proxy.reload: Exceptional-completion cause for KafkaProxy.reconfigure(Configuration) when the submitted configuration differs from the running configuration in any static section — i.e. a section the proxy does not reconcile at runtime.
StaticConfigurationChangedException(Set<String>) - Constructor for exception class io.kroxylicious.proxy.reload.StaticConfigurationChangedException
stop() - Method in class io.kroxylicious.proxy.internal.VirtualClusterLifecycle: Transitions to VirtualClusterLifecycleState.Stopped from VirtualClusterLifecycleState.Failed or VirtualClusterLifecycleState.Initializing.
Stopped(Throwable) - Constructor for record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Stopped: Creates an instance of a Stopped record class.
StreamsGroupDescribeRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for StreamsGroupDescribeRequestFilter.
StreamsGroupDescribeRequestFilterInvoker(StreamsGroupDescribeRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.StreamsGroupDescribeRequestFilterInvoker
StreamsGroupDescribeResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for StreamsGroupDescribeResponseFilter.
StreamsGroupDescribeResponseFilterInvoker(StreamsGroupDescribeResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.StreamsGroupDescribeResponseFilterInvoker
StreamsGroupHeartbeatRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for StreamsGroupHeartbeatRequestFilter.
StreamsGroupHeartbeatRequestFilterInvoker(StreamsGroupHeartbeatRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.StreamsGroupHeartbeatRequestFilterInvoker
StreamsGroupHeartbeatResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for StreamsGroupHeartbeatResponseFilter.
StreamsGroupHeartbeatResponseFilterInvoker(StreamsGroupHeartbeatResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.StreamsGroupHeartbeatResponseFilterInvoker
subject() - Static method in interface io.kroxylicious.proxy.internal.subject.TlsCertificateExtractor
subjectBuilder() - Method in record class io.kroxylicious.proxy.config.VirtualCluster: Returns the value of the subjectBuilder record component.
subjectBuilder(PluginFactoryRegistry) - Method in class io.kroxylicious.proxy.model.VirtualClusterModel
subjectFromTransport(SSLSession, TransportSubjectBuilder, Executor, Runnable) - Method in class io.kroxylicious.proxy.internal.ClientSubjectManager
submit(Runnable) - Method in class io.kroxylicious.proxy.internal.NettyFilterDispatchExecutor
submit(Runnable, T) - Method in class io.kroxylicious.proxy.internal.NettyFilterDispatchExecutor
submit(Callable<T>) - Method in class io.kroxylicious.proxy.internal.NettyFilterDispatchExecutor
supports(Configuration) - Method in class io.kroxylicious.proxy.internal.config.Features: Check whether this configuration is supported by the proxy's features
supports(Configuration, boolean) - Method in enum class io.kroxylicious.proxy.internal.config.Feature: Check if a configuration is supported by this feature
SyncGroupRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for SyncGroupRequestFilter.
SyncGroupRequestFilterInvoker(SyncGroupRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.SyncGroupRequestFilterInvoker
SyncGroupResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for SyncGroupResponseFilter.
SyncGroupResponseFilterInvoker(SyncGroupResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.SyncGroupResponseFilterInvoker

T

tag(RequestHeaderData, RequestHeaderTagger.Tag) - Static method in class io.kroxylicious.proxy.internal.util.RequestHeaderTagger
taggedCounter(String, List<Tag>) - Static method in class io.kroxylicious.proxy.internal.util.Metrics
tags(String...) - Static method in class io.kroxylicious.proxy.internal.util.Metrics
tags(String, String) - Static method in class io.kroxylicious.proxy.internal.util.Metrics
tags(String, String, String, String) - Static method in class io.kroxylicious.proxy.internal.util.Metrics
target() - Method in record class io.kroxylicious.proxy.config.RouteDefinition: Returns the value of the target record component.
target() - Method in record class io.kroxylicious.proxy.config.VirtualCluster: Returns the value of the target record component.
targetCluster() - Method in record class io.kroxylicious.proxy.config.VirtualCluster: Deprecated, for removal: This API element is subject to removal in a future version.
targetCluster() - Method in record class io.kroxylicious.proxy.internal.routing.RouteDescriptor: Returns the value of the targetCluster record component.
targetCluster() - Method in record class io.kroxylicious.proxy.internal.routing.UpstreamClusterModel: Returns the value of the targetCluster record component.
TargetCluster - Record Class in io.kroxylicious.proxy.config: Represents the target (upstream) kafka cluster.
TargetCluster(String, Optional<Tls>) - Constructor for record class io.kroxylicious.proxy.config.TargetCluster
TargetCluster(String, Optional<Tls>, BootstrapSelectionStrategy) - Constructor for record class io.kroxylicious.proxy.config.TargetCluster: Creates an instance of a TargetCluster record class.
targetNodeId() - Method in record class io.kroxylicious.proxy.internal.routing.NodeIdMapping.RouteAndNode: Returns the value of the targetNodeId record component.
targetsCluster() - Method in record class io.kroxylicious.proxy.internal.routing.RouteDescriptor: Returns true if this route targets a Kafka cluster.
targetsRouter() - Method in record class io.kroxylicious.proxy.internal.routing.RouteDescriptor: Returns true if this route targets a nested router.
TERMINATING - Enum constant in enum class io.kroxylicious.proxy.internal.KafkaSessionState: The session is being torn down by the proxy.
TEST_ONLY_CONFIGURATION - Enum constant in enum class io.kroxylicious.proxy.internal.config.Feature: Enables loading specific nodes in the configuration file which configure test-only features.
tls - Variable in class io.kroxylicious.proxy.internal.net.NetworkBindingOperation
tls() - Method in record class io.kroxylicious.proxy.config.ClusterDefinition: Returns the value of the tls record component.
tls() - Method in record class io.kroxylicious.proxy.config.TargetCluster: Returns the value of the tls record component.
tls() - Method in record class io.kroxylicious.proxy.config.VirtualClusterGateway: Returns the value of the tls record component.
tls() - Method in record class io.kroxylicious.proxy.internal.net.Endpoint: Returns the value of the tls record component.
tls() - Method in class io.kroxylicious.proxy.internal.net.NetworkBindingOperation: Indicates whether the binding is to be used for TLS.
tls() - Method in record class io.kroxylicious.proxy.internal.routing.UpstreamClusterModel
TlsCertificateExtractor - Interface in io.kroxylicious.proxy.internal.subject
TlsCertificateExtractor.Asn1SanNameType - Enum Class in io.kroxylicious.proxy.internal.subject
tlsCredentials(PrivateKey, X509Certificate[]) - Method in class io.kroxylicious.proxy.internal.tls.ServerTlsCredentialSupplierContextImpl
TlsCredentialsImpl - Record Class in io.kroxylicious.proxy.internal.tls: Runtime implementation of TlsCredentials containing the actual private key and certificate chain.
TlsCredentialsImpl(PrivateKey, X509Certificate[]) - Constructor for record class io.kroxylicious.proxy.internal.tls.TlsCredentialsImpl: Creates an instance of a TlsCredentialsImpl record class.
TlsCredentialSupplierManager - Class in io.kroxylicious.proxy.bootstrap: Manages the lifecycle of TLS credential supplier plugin instances.
TlsCredentialSupplierManager(PluginFactoryRegistry, TlsCredentialSupplierConfig) - Constructor for class io.kroxylicious.proxy.bootstrap.TlsCredentialSupplierManager: Creates a TlsCredentialSupplierManager for the given target cluster definition.
tlsManager() - Method in record class io.kroxylicious.proxy.internal.routing.UpstreamClusterModel: Returns the value of the tlsManager record component.
TlsUtil - Class in io.kroxylicious.proxy.internal.tls: Utility class for TLS credential validation.
tlvs() - Method in record class io.kroxylicious.proxy.internal.net.HaProxyContext: Returns a defensive copy of the TLV map to prevent mutation of internal state.
TO_STATE_LABEL - Static variable in class io.kroxylicious.proxy.internal.util.Metrics
toDraining(Duration) - Method in record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Serving: The cluster is being shut down or reconfigured.
toFailed(Throwable) - Method in record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Initializing: Configuration could not be applied.
toIntervalNotationString() - Method in record class io.kroxylicious.proxy.config.NamedRange
topicNameCache() - Method in record class io.kroxylicious.proxy.config.VirtualCluster: Returns the value of the topicNameCache record component.
TopicNameCacheFilter - Class in io.kroxylicious.proxy.internal.filter.impl: A Filter that learns and caches all topic names, it is responsible for short circuit responding to internal topic name retrievals.
TopicNameCacheFilter(CacheConfiguration, String) - Constructor for class io.kroxylicious.proxy.internal.filter.impl.TopicNameCacheFilter
TopicNameCacheFilter(CacheConfiguration, Map<Uuid, String>, String) - Constructor for class io.kroxylicious.proxy.internal.filter.impl.TopicNameCacheFilter
TopicNameRetriever - Class in io.kroxylicious.proxy.internal
toServing() - Method in record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Initializing: Configuration applied successfully.
toStopped() - Method in record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Draining: Drain complete, cluster permanently removed.
toStopped() - Method in record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Failed: The cluster is being permanently removed.
toStopped() - Method in record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Initializing: Cluster removed before initialization completed (e.g. proxy shutdown during startup).
toString() - Method in record class io.kroxylicious.proxy.config.admin.EndpointsConfiguration: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.admin.ManagementConfiguration: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.admin.PrometheusMetricsConfig: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.CacheConfiguration: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.ClusterDefinition: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.Configuration: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.MicrometerDefinition: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.NamedFilterDefinition: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.NamedRange: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.NettySettings: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.NetworkDefinition: Returns a string representation of this record class.
toString() - Method in class io.kroxylicious.proxy.config.PortIdentifiesNodeIdentificationStrategy
toString() - Method in record class io.kroxylicious.proxy.config.ProxyProtocolConfig: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.Range: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.RouteDefinition: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.RouterDefinition: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.RouteTarget: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.ServiceBasedPluginFactoryRegistry.ProviderAndConfigType: Returns a string representation of this record class.
toString() - Method in class io.kroxylicious.proxy.config.SniHostIdentifiesNodeIdentificationStrategy
toString() - Method in record class io.kroxylicious.proxy.config.TargetCluster: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.TransportSubjectBuilderConfig: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.VirtualCluster: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.config.VirtualClusterGateway: Returns a string representation of this record class.
toString() - Method in class io.kroxylicious.proxy.frame.DecodedFrame
toString() - Method in class io.kroxylicious.proxy.frame.OpaqueFrame
toString() - Method in class io.kroxylicious.proxy.frame.OpaqueRequestFrame
toString() - Method in class io.kroxylicious.proxy.frame.OpaqueResponseFrame
toString() - Method in class io.kroxylicious.proxy.internal.ClientConnectionStateMachine
toString() - Method in class io.kroxylicious.proxy.internal.codec.CorrelationManager.Correlation
toString() - Method in class io.kroxylicious.proxy.internal.config.Features
toString() - Method in record class io.kroxylicious.proxy.internal.filter.FilterAndInvoker: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.filter.HandleNothingFilterInvoker: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.filter.RequestFilterInvoker: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.filter.RequestResponseInvoker: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.filter.ResponseFilterInvoker: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.filter.SafeInvoker: Returns a string representation of this record class.
toString() - Method in class io.kroxylicious.proxy.internal.FilterHandler
toString() - Method in class io.kroxylicious.proxy.internal.InternalResponseFrame
toString() - Method in class io.kroxylicious.proxy.internal.KafkaProxyBackendHandler
toString() - Method in class io.kroxylicious.proxy.internal.KafkaProxyFrontendHandler
toString() - Method in class io.kroxylicious.proxy.internal.KafkaSession
toString() - Method in record class io.kroxylicious.proxy.internal.net.BootstrapEndpointBinding: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.net.BrokerEndpointBinding: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.net.Endpoint: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.net.HaProxyContext: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.net.MetadataDiscoveryBrokerEndpointBinding: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.routing.BijectiveNodeIdMapping: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.routing.DirectRouting: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.routing.DynamicRouting: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.routing.IdentityNodeIdMapping: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.routing.NodeIdMapping.RouteAndNode: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.routing.RouteDescriptor: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.routing.UpstreamClusterModel: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.subject.DefaultSaslSubjectBuilderService.Config: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.subject.DefaultTransportSubjectBuilderService.Config: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.subject.Map: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.subject.PrincipalAdder: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.subject.PrincipalAdderConf: Returns a string representation of this record class.
toString() - Method in class io.kroxylicious.proxy.internal.subject.ReplaceMatchMappingRule
toString() - Method in record class io.kroxylicious.proxy.internal.subject.Rule: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.tls.TlsCredentialsImpl: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.util.VirtualClusterNode: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Draining: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Failed: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Initializing: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Serving: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.internal.VirtualClusterLifecycleState.Stopped: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.micrometer.CommonTagsHook.CommonTagsHookConfig: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.micrometer.PauseDetectorHook.PauseDetectorHookConfig: Returns a string representation of this record class.
toString() - Method in record class io.kroxylicious.proxy.micrometer.StandardBindersHook.StandardBindersHookConfig: Returns a string representation of this record class.
toString() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel
toString() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel.VirtualClusterGatewayModel
toString() - Method in record class io.kroxylicious.proxy.reload.ReconfigureError: Returns a string representation of this record class.
toString() - Method in class io.kroxylicious.proxy.service.HostPort
totalRoutes() - Method in record class io.kroxylicious.proxy.internal.routing.BijectiveNodeIdMapping: Returns the value of the totalRoutes record component.
toTargetCluster() - Method in record class io.kroxylicious.proxy.config.ClusterDefinition: Converts this definition to a TargetCluster for use in the runtime.
touch(Object) - Method in class io.kroxylicious.proxy.frame.DecodedFrame
toVirtual(String, int) - Method in record class io.kroxylicious.proxy.internal.routing.BijectiveNodeIdMapping
toVirtual(String, int) - Method in record class io.kroxylicious.proxy.internal.routing.IdentityNodeIdMapping
toVirtual(String, int) - Method in interface io.kroxylicious.proxy.internal.routing.NodeIdMapping: Translates a target-cluster node ID to a virtual node ID.
toYaml(Configuration) - Method in class io.kroxylicious.proxy.config.ConfigParser
transferBuffersTo(DecodedFrame<?, ?>) - Method in class io.kroxylicious.proxy.frame.DecodedFrame
transitionTo(KafkaSessionState) - Method in class io.kroxylicious.proxy.internal.KafkaSession
TRANSPORT_AUTHENTICATED - Enum constant in enum class io.kroxylicious.proxy.internal.KafkaSessionState: The client has been successfully authenticated based on details of network connection.
TransportSubjectBuilderConfig - Record Class in io.kroxylicious.proxy.config
TransportSubjectBuilderConfig(String, Object) - Constructor for record class io.kroxylicious.proxy.config.TransportSubjectBuilderConfig: Creates an instance of a TransportSubjectBuilderConfig record class.
TxnOffsetCommitRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for TxnOffsetCommitRequestFilter.
TxnOffsetCommitRequestFilterInvoker(TxnOffsetCommitRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.TxnOffsetCommitRequestFilterInvoker
TxnOffsetCommitResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for TxnOffsetCommitResponseFilter.
TxnOffsetCommitResponseFilterInvoker(TxnOffsetCommitResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.TxnOffsetCommitResponseFilterInvoker
type() - Method in record class io.kroxylicious.proxy.config.MicrometerDefinition: Returns the value of the type record component.
type() - Method in record class io.kroxylicious.proxy.config.NamedFilterDefinition: Returns the value of the type record component.
type() - Method in record class io.kroxylicious.proxy.config.RouterDefinition: Returns the value of the type record component.
type() - Method in record class io.kroxylicious.proxy.config.TransportSubjectBuilderConfig: Returns the value of the type record component.
typeFromId(DatabindContext, String) - Method in class io.kroxylicious.proxy.config.PluginConfigTypeIdResolver

U

unauthenticatedIdleTimeout() - Method in record class io.kroxylicious.proxy.config.NettySettings: Returns the value of the unauthenticatedIdleTimeout record component.
unconfigured() - Static method in class io.kroxylicious.proxy.bootstrap.TlsCredentialSupplierManager: Returns an unconfigured manager singleton (null-object pattern).
Understanding the Kroxylicious Pipeline - Search tag in package io.kroxylicious.proxy.internal: Section
UnregisterBrokerRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for UnregisterBrokerRequestFilter.
UnregisterBrokerRequestFilterInvoker(UnregisterBrokerRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.UnregisterBrokerRequestFilterInvoker
UnregisterBrokerResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for UnregisterBrokerResponseFilter.
UnregisterBrokerResponseFilterInvoker(UnregisterBrokerResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.UnregisterBrokerResponseFilterInvoker
UnresolvedHostException(String) - Constructor for exception class io.kroxylicious.proxy.config.SniHostIdentifiesNodeIdentificationStrategy.UnresolvedHostException
UpdateFeaturesRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for UpdateFeaturesRequestFilter.
UpdateFeaturesRequestFilterInvoker(UpdateFeaturesRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.UpdateFeaturesRequestFilterInvoker
UpdateFeaturesResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for UpdateFeaturesResponseFilter.
UpdateFeaturesResponseFilterInvoker(UpdateFeaturesResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.UpdateFeaturesResponseFilterInvoker
UpdateRaftVoterRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for UpdateRaftVoterRequestFilter.
UpdateRaftVoterRequestFilterInvoker(UpdateRaftVoterRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.UpdateRaftVoterRequestFilterInvoker
UpdateRaftVoterResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for UpdateRaftVoterResponseFilter.
UpdateRaftVoterResponseFilterInvoker(UpdateRaftVoterResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.UpdateRaftVoterResponseFilterInvoker
updateVersions(String, ApiVersionsResponseData) - Method in class io.kroxylicious.proxy.internal.ApiVersionsServiceImpl
updateVirtualClusterState(String, String) - Static method in class io.kroxylicious.proxy.internal.util.Metrics: Updates the kroxylicious_virtual_cluster_state state-set gauge so the series for state reads 1 and every other state for clusterName reads 0.
upstreamAddress(EndpointGateway, int) - Method in interface io.kroxylicious.proxy.internal.net.EndpointReconciler: Returns the upstream address for the given upstream node ID (note this may be a physical node id, or a virtual node id if routing enabled), as last reconciled for the virtual cluster identified by gateway.
upstreamAddress(EndpointGateway, int) - Method in class io.kroxylicious.proxy.internal.net.EndpointRegistry
upstreamCluster() - Method in record class io.kroxylicious.proxy.internal.routing.DirectRouting: Returns the value of the upstreamCluster record component.
upstreamClusterFor(String) - Method in record class io.kroxylicious.proxy.internal.routing.DirectRouting
upstreamClusterFor(String) - Method in record class io.kroxylicious.proxy.internal.routing.DynamicRouting
upstreamClusterFor(String) - Method in interface io.kroxylicious.proxy.internal.routing.RoutingModel: Returns the UpstreamClusterModel for the given route name
UpstreamClusterModel - Record Class in io.kroxylicious.proxy.internal.routing: Runtime representation of an upstream Kafka cluster, bundling its connection target with the TLS resources needed to reach it.
UpstreamClusterModel(TargetCluster, Optional<SslContext>, TlsCredentialSupplierManager) - Constructor for record class io.kroxylicious.proxy.internal.routing.UpstreamClusterModel: Creates an instance of a UpstreamClusterModel record class.
upstreamSslContext() - Method in record class io.kroxylicious.proxy.internal.routing.UpstreamClusterModel: Returns the value of the upstreamSslContext record component.
upstreamTarget() - Method in record class io.kroxylicious.proxy.internal.net.BootstrapEndpointBinding
upstreamTarget() - Method in record class io.kroxylicious.proxy.internal.net.BrokerEndpointBinding: Returns the value of the upstreamTarget record component.
upstreamTarget() - Method in interface io.kroxylicious.proxy.internal.net.EndpointBinding: The upstream target of this binding.
upstreamTarget() - Method in record class io.kroxylicious.proxy.internal.net.MetadataDiscoveryBrokerEndpointBinding
URI - Enum constant in enum class io.kroxylicious.proxy.internal.subject.TlsCertificateExtractor.Asn1SanNameType
useIoUring() - Method in record class io.kroxylicious.proxy.config.Configuration: Returns the value of the useIoUring record component.
userEventTriggered(ChannelHandlerContext, Object) - Method in class io.kroxylicious.proxy.internal.KafkaProxyBackendHandler: Netty callback.
userEventTriggered(ChannelHandlerContext, Object) - Method in class io.kroxylicious.proxy.internal.KafkaProxyFrontendHandler: Netty callback.
usesDynamicTlsCredentials() - Method in record class io.kroxylicious.proxy.internal.routing.UpstreamClusterModel
usesDynamicTlsCredentials() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel: Checks if this virtual cluster uses dynamic TLS credential supplier.

V

validate(Collection<VirtualClusterModel>, Optional<HostPort>) - Method in class io.kroxylicious.proxy.internal.PortConflictDetector: Validates the configuration throwing an exception if a conflict is detected.
validateCertificateChain(PrivateKey, X509Certificate[]) - Static method in class io.kroxylicious.proxy.internal.tls.TlsUtil: Validates the certificate chain integrity and parameters.
validateForward(H, ApiMessage) - Method in class io.kroxylicious.proxy.internal.filter.FilterResultBuilderImpl
validateForward(RequestHeaderData, ApiMessage) - Method in class io.kroxylicious.proxy.internal.filter.RequestFilterResultBuilderImpl
validateForward(ResponseHeaderData, ApiMessage) - Method in class io.kroxylicious.proxy.internal.filter.ResponseFilterResultBuilderImpl
valueOf(String) - Static method in enum class io.kroxylicious.proxy.config.ProxyProtocolMode: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.kroxylicious.proxy.internal.ClientConnectionStateMachine.DisconnectCause: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.kroxylicious.proxy.internal.config.Feature: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.kroxylicious.proxy.internal.KafkaSessionState: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.kroxylicious.proxy.internal.subject.TlsCertificateExtractor.Asn1SanNameType: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.kroxylicious.proxy.internal.util.RequestHeaderTagger.Tag: Returns the enum constant of this class with the specified name.
values() - Method in record class io.kroxylicious.proxy.config.NamedRange: Provides a Stream of values contained in the range
values() - Static method in enum class io.kroxylicious.proxy.config.ProxyProtocolMode: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Method in record class io.kroxylicious.proxy.config.Range: Provides a Stream of values contained in the range
values() - Static method in enum class io.kroxylicious.proxy.internal.ClientConnectionStateMachine.DisconnectCause: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.kroxylicious.proxy.internal.config.Feature: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.kroxylicious.proxy.internal.KafkaSessionState: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.kroxylicious.proxy.internal.subject.TlsCertificateExtractor.Asn1SanNameType: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.kroxylicious.proxy.internal.util.RequestHeaderTagger.Tag: Returns an array containing the constants of this enum class, in the order they are declared.
version() - Method in class io.kroxylicious.proxy.VersionInfo.Info
version() - Method in interface io.kroxylicious.proxy.VersionInfo
VERSION_INFO - Static variable in interface io.kroxylicious.proxy.VersionInfo: Version information loaded from the default Kroxylicious runtime metadata resource, META-INF/metadata.properties.
VersionInfo - Interface in io.kroxylicious.proxy
VersionInfo.Info - Class in io.kroxylicious.proxy
versionInfoMetric(VersionInfo) - Static method in class io.kroxylicious.proxy.internal.util.Metrics: Exposes a build info metric describing Kroxylicious version etc.
VIRTUAL_CLUSTER_CANNOT_BE_NULL_MESSAGE - Static variable in class io.kroxylicious.proxy.internal.net.EndpointRegistry
VIRTUAL_CLUSTER_LABEL - Static variable in class io.kroxylicious.proxy.internal.util.Metrics
virtualCluster() - Method in interface io.kroxylicious.proxy.internal.net.EndpointGateway
virtualCluster() - Method in class io.kroxylicious.proxy.model.VirtualClusterModel.VirtualClusterGatewayModel
VirtualCluster - Record Class in io.kroxylicious.proxy.config: A virtual cluster.
VirtualCluster(String, TargetCluster, RouteTarget, List<VirtualClusterGateway>, boolean, boolean, List<String>, TransportSubjectBuilderConfig, CacheConfiguration, Duration) - Constructor for record class io.kroxylicious.proxy.config.VirtualCluster: Creates an instance of a VirtualCluster record class.
VirtualCluster(String, TargetCluster, List<VirtualClusterGateway>, boolean, boolean, List<String>) - Constructor for record class io.kroxylicious.proxy.config.VirtualCluster
VirtualClusterGateway - Record Class in io.kroxylicious.proxy.config: A virtual cluster listener.
VirtualClusterGateway(String, PortIdentifiesNodeIdentificationStrategy, SniHostIdentifiesNodeIdentificationStrategy, Optional<Tls>) - Constructor for record class io.kroxylicious.proxy.config.VirtualClusterGateway: Creates an instance of a VirtualClusterGateway record class.
VirtualClusterLifecycle - Class in io.kroxylicious.proxy.internal: Manages the lifecycle state of a single virtual cluster.
VirtualClusterLifecycle(String, Duration) - Constructor for class io.kroxylicious.proxy.internal.VirtualClusterLifecycle
VirtualClusterLifecycleState - Interface in io.kroxylicious.proxy.internal: Lifecycle states for a virtual cluster.
VirtualClusterLifecycleState.Draining - Record Class in io.kroxylicious.proxy.internal: New connections are rejected.
VirtualClusterLifecycleState.Failed - Record Class in io.kroxylicious.proxy.internal: Configuration was not viable.
VirtualClusterLifecycleState.Initializing - Record Class in io.kroxylicious.proxy.internal: The cluster is being set up.
VirtualClusterLifecycleState.Serving - Record Class in io.kroxylicious.proxy.internal: The proxy has completed setup and is serving traffic for this cluster.
VirtualClusterLifecycleState.Stopped - Record Class in io.kroxylicious.proxy.internal: Terminal state.
virtualClusterModel(PluginFactoryRegistry) - Method in record class io.kroxylicious.proxy.config.Configuration
virtualClusterModel(PluginFactoryRegistry, String) - Method in record class io.kroxylicious.proxy.config.Configuration: Builds the VirtualClusterModel for a single virtual cluster by name.
VirtualClusterModel - Class in io.kroxylicious.proxy.model: Runtime representation of a virtual cluster: its name, target Kafka cluster, gateways, TLS configuration, and the components whose lifecycle is bound to this VC.
VirtualClusterModel(String, TargetCluster, boolean, boolean, List<NamedFilterDefinition>) - Constructor for class io.kroxylicious.proxy.model.VirtualClusterModel
VirtualClusterModel(String, RoutingModel, boolean, boolean, List<NamedFilterDefinition>, CacheConfiguration, TransportSubjectBuilderConfig, Duration, PluginFactoryRegistry) - Constructor for class io.kroxylicious.proxy.model.VirtualClusterModel
VirtualClusterModel.VirtualClusterGatewayModel - Class in io.kroxylicious.proxy.model
virtualClusterModels() - Method in class io.kroxylicious.proxy.internal.VirtualClusterRegistry: Returns the currently-tracked virtual cluster models.
VirtualClusterNode - Record Class in io.kroxylicious.proxy.internal.util: Represents a node in a virtual cluster, identified by its cluster name and an optional node ID.
VirtualClusterNode(String, Integer) - Constructor for record class io.kroxylicious.proxy.internal.util.VirtualClusterNode: Creates an instance of a VirtualClusterNode record class.
VirtualClusterRegistry - Class in io.kroxylicious.proxy.internal: Owns the virtual cluster configuration tree and lifecycle state.
VirtualClusterRegistry(List<VirtualClusterModel>, BiFunction<Configuration, String, VirtualClusterModel>, BiConsumer<String, Optional<Throwable>>) - Constructor for class io.kroxylicious.proxy.internal.VirtualClusterRegistry: Creates a new VirtualClusterRegistry for the given set of virtual clusters.
virtualClusters() - Method in record class io.kroxylicious.proxy.config.Configuration: Returns the value of the virtualClusters record component.
virtualClusterStateDurationTimer(String, String) - Static method in class io.kroxylicious.proxy.internal.util.Metrics: Timer for the time a virtual cluster spent in a given lifecycle state (recorded when it leaves that state).
virtualClusterTransitionsCounter(String, String, String) - Static method in class io.kroxylicious.proxy.internal.util.Metrics: Counter of virtual cluster lifecycle state transitions, tagged by from and to state.
VoteRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for VoteRequestFilter.
VoteRequestFilterInvoker(VoteRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.VoteRequestFilterInvoker
VoteResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for VoteResponseFilter.
VoteResponseFilterInvoker(VoteResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.VoteResponseFilterInvoker

W

warnings() - Method in class io.kroxylicious.proxy.internal.config.Features: If any sensitive or unsupported features are enabled, they may return a warning to be logged
What it does - Search tag in class io.kroxylicious.proxy.bootstrap.FilterChainFactory: Section
What it holds - Search tag in class io.kroxylicious.proxy.bootstrap.FilterChainFactory: Section
withCloseConnection() - Method in class io.kroxylicious.proxy.internal.filter.FilterResultBuilderImpl
withConfig(String, Object) - Method in class io.kroxylicious.proxy.config.AbstractDefinitionBuilder
withConfig(String, Object, String, Object) - Method in class io.kroxylicious.proxy.config.AbstractDefinitionBuilder
withConfig(String, Object, String, Object, String, Object) - Method in class io.kroxylicious.proxy.config.AbstractDefinitionBuilder
withConfig(String, Object, String, Object, String, Object, String, Object) - Method in class io.kroxylicious.proxy.config.AbstractDefinitionBuilder
withConfig(Map<String, Object>) - Method in class io.kroxylicious.proxy.config.AbstractDefinitionBuilder
workerThreadCount() - Method in record class io.kroxylicious.proxy.config.NettySettings: Returns the value of the workerThreadCount record component.
write(byte[], int, int) - Method in class io.kroxylicious.proxy.internal.util.ByteBufOutputStream
write(int) - Method in class io.kroxylicious.proxy.internal.util.ByteBufOutputStream
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class io.kroxylicious.proxy.internal.FilterHandler: Handles outbound responses flowing toward the client.
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class io.kroxylicious.proxy.internal.ResponseOrderer
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class io.kroxylicious.proxy.internal.routing.RouterDispatchHandler
write(ByteBuffer) - Method in class io.kroxylicious.proxy.internal.util.ByteBufOutputStream
writeByte(byte) - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
writeByte(byte) - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
writeByteArray(byte[]) - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
writeByteArray(byte[]) - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
writeByteBuffer(ByteBuffer) - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
writeByteBuffer(ByteBuffer) - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
writeBytes(ByteBuf, int) - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
writeBytes(ByteBuf, int) - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
writeDouble(double) - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
writeDouble(double) - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
writeInt(int) - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
writeInt(int) - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
writeLong(long) - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
writeLong(long) - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
writerIndex() - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
writerIndex() - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
WriteShareGroupStateRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for WriteShareGroupStateRequestFilter.
WriteShareGroupStateRequestFilterInvoker(WriteShareGroupStateRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.WriteShareGroupStateRequestFilterInvoker
WriteShareGroupStateResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for WriteShareGroupStateResponseFilter.
WriteShareGroupStateResponseFilterInvoker(WriteShareGroupStateResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.WriteShareGroupStateResponseFilterInvoker
writeShort(short) - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
writeShort(short) - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
WriteTxnMarkersRequestFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for WriteTxnMarkersRequestFilter.
WriteTxnMarkersRequestFilterInvoker(WriteTxnMarkersRequestFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.WriteTxnMarkersRequestFilterInvoker
WriteTxnMarkersResponseFilterInvoker - Class in io.kroxylicious.proxy.internal.filter: An invoker for WriteTxnMarkersResponseFilter.
WriteTxnMarkersResponseFilterInvoker(WriteTxnMarkersResponseFilter) - Constructor for class io.kroxylicious.proxy.internal.filter.WriteTxnMarkersResponseFilterInvoker
writeUnsignedVarint(int) - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
writeUnsignedVarint(int) - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
writeUnsignedVarint(int, ByteBuf) - Static method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
writeVarint(int) - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
writeVarint(int) - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
writeVarint(int, ByteBuf) - Static method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
writeVarlong(long) - Method in interface io.kroxylicious.proxy.frame.ByteBufAccessor
writeVarlong(long) - Method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl
writeVarlong(long, ByteBuf) - Static method in class io.kroxylicious.proxy.internal.codec.ByteBufAccessorImpl

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