Package io.kroxylicious.proxy.internal.filter
@ReturnValuesAreNonnullByDefault
@DefaultAnnotationForParameters(edu.umd.cs.findbugs.annotations.NonNull.class)
@DefaultAnnotation(edu.umd.cs.findbugs.annotations.NonNull.class)
package io.kroxylicious.proxy.internal.filter
-
ClassDescriptionAn invoker for AddOffsetsToTxnRequestFilter.An invoker for AddOffsetsToTxnResponseFilter.An invoker for AddPartitionsToTxnRequestFilter.An invoker for AddPartitionsToTxnResponseFilter.An invoker for AddRaftVoterRequestFilter.An invoker for AddRaftVoterResponseFilter.An invoker for AllocateProducerIdsRequestFilter.An invoker for AllocateProducerIdsResponseFilter.An invoker for AlterClientQuotasRequestFilter.An invoker for AlterClientQuotasResponseFilter.An invoker for AlterConfigsRequestFilter.An invoker for AlterConfigsResponseFilter.An invoker for AlterPartitionReassignmentsRequestFilter.An invoker for AlterPartitionReassignmentsResponseFilter.An invoker for AlterPartitionRequestFilter.An invoker for AlterPartitionResponseFilter.An invoker for AlterReplicaLogDirsRequestFilter.An invoker for AlterReplicaLogDirsResponseFilter.An invoker for AlterShareGroupOffsetsRequestFilter.An invoker for AlterShareGroupOffsetsResponseFilter.An invoker for AlterUserScramCredentialsRequestFilter.An invoker for AlterUserScramCredentialsResponseFilter.An invoker for ApiVersionsRequestFilter.An invoker for ApiVersionsResponseFilter.An invoker for AssignReplicasToDirsRequestFilter.An invoker for AssignReplicasToDirsResponseFilter.An invoker for BeginQuorumEpochRequestFilter.An invoker for BeginQuorumEpochResponseFilter.An invoker for BrokerHeartbeatRequestFilter.An invoker for BrokerHeartbeatResponseFilter.An invoker for BrokerRegistrationRequestFilter.An invoker for BrokerRegistrationResponseFilter.An invoker for ConsumerGroupDescribeRequestFilter.An invoker for ConsumerGroupDescribeResponseFilter.An invoker for ConsumerGroupHeartbeatRequestFilter.An invoker for ConsumerGroupHeartbeatResponseFilter.An invoker for ControllerRegistrationRequestFilter.An invoker for ControllerRegistrationResponseFilter.An invoker for CreateAclsRequestFilter.An invoker for CreateAclsResponseFilter.An invoker for CreateDelegationTokenRequestFilter.An invoker for CreateDelegationTokenResponseFilter.An invoker for CreatePartitionsRequestFilter.An invoker for CreatePartitionsResponseFilter.An invoker for CreateTopicsRequestFilter.An invoker for CreateTopicsResponseFilter.An invoker for DeleteAclsRequestFilter.An invoker for DeleteAclsResponseFilter.An invoker for DeleteGroupsRequestFilter.An invoker for DeleteGroupsResponseFilter.An invoker for DeleteRecordsRequestFilter.An invoker for DeleteRecordsResponseFilter.An invoker for DeleteShareGroupOffsetsRequestFilter.An invoker for DeleteShareGroupOffsetsResponseFilter.An invoker for DeleteShareGroupStateRequestFilter.An invoker for DeleteShareGroupStateResponseFilter.An invoker for DeleteTopicsRequestFilter.An invoker for DeleteTopicsResponseFilter.An invoker for DescribeAclsRequestFilter.An invoker for DescribeAclsResponseFilter.An invoker for DescribeClientQuotasRequestFilter.An invoker for DescribeClientQuotasResponseFilter.An invoker for DescribeClusterRequestFilter.An invoker for DescribeClusterResponseFilter.An invoker for DescribeConfigsRequestFilter.An invoker for DescribeConfigsResponseFilter.An invoker for DescribeDelegationTokenRequestFilter.An invoker for DescribeDelegationTokenResponseFilter.An invoker for DescribeGroupsRequestFilter.An invoker for DescribeGroupsResponseFilter.An invoker for DescribeLogDirsRequestFilter.An invoker for DescribeLogDirsResponseFilter.An invoker for DescribeProducersRequestFilter.An invoker for DescribeProducersResponseFilter.An invoker for DescribeQuorumRequestFilter.An invoker for DescribeQuorumResponseFilter.An invoker for DescribeShareGroupOffsetsRequestFilter.An invoker for DescribeShareGroupOffsetsResponseFilter.An invoker for DescribeTopicPartitionsRequestFilter.An invoker for DescribeTopicPartitionsResponseFilter.An invoker for DescribeTransactionsRequestFilter.An invoker for DescribeTransactionsResponseFilter.An invoker for DescribeUserScramCredentialsRequestFilter.An invoker for DescribeUserScramCredentialsResponseFilter.An invoker for ElectLeadersRequestFilter.An invoker for ElectLeadersResponseFilter.An invoker for EndQuorumEpochRequestFilter.An invoker for EndQuorumEpochResponseFilter.An invoker for EndTxnRequestFilter.An invoker for EndTxnResponseFilter.An invoker for EnvelopeRequestFilter.An invoker for EnvelopeResponseFilter.An invoker for ExpireDelegationTokenRequestFilter.An invoker for ExpireDelegationTokenResponseFilter.An invoker for FetchRequestFilter.An invoker for FetchResponseFilter.An invoker for FetchSnapshotRequestFilter.An invoker for FetchSnapshotResponseFilter.A Filter and it's respective invokerThe FilterInvoker connects Kroxylicious with the concrete implementation of a Filter.Factory for FilterInvokers.FilterResultBuilderImpl<H extends org.apache.kafka.common.protocol.ApiMessage,
R extends io.kroxylicious.proxy.filter.FilterResult> An invoker for FindCoordinatorRequestFilter.An invoker for FindCoordinatorResponseFilter.An invoker for GetTelemetrySubscriptionsRequestFilter.An invoker for GetTelemetrySubscriptionsResponseFilter.An invoker for HeartbeatRequestFilter.An invoker for HeartbeatResponseFilter.An invoker for IncrementalAlterConfigsRequestFilter.An invoker for IncrementalAlterConfigsResponseFilter.An invoker for InitializeShareGroupStateRequestFilter.An invoker for InitializeShareGroupStateResponseFilter.An invoker for InitProducerIdRequestFilter.An invoker for InitProducerIdResponseFilter.An invoker for JoinGroupRequestFilter.An invoker for JoinGroupResponseFilter.An invoker for LeaveGroupRequestFilter.An invoker for LeaveGroupResponseFilter.An invoker for ListConfigResourcesRequestFilter.An invoker for ListConfigResourcesResponseFilter.An invoker for ListGroupsRequestFilter.An invoker for ListGroupsResponseFilter.An invoker for ListOffsetsRequestFilter.An invoker for ListOffsetsResponseFilter.An invoker for ListPartitionReassignmentsRequestFilter.An invoker for ListPartitionReassignmentsResponseFilter.An invoker for ListTransactionsRequestFilter.An invoker for ListTransactionsResponseFilter.An invoker for MetadataRequestFilter.An invoker for MetadataResponseFilter.An invoker for OffsetCommitRequestFilter.An invoker for OffsetCommitResponseFilter.An invoker for OffsetDeleteRequestFilter.An invoker for OffsetDeleteResponseFilter.An invoker for OffsetFetchRequestFilter.An invoker for OffsetFetchResponseFilter.An invoker for OffsetForLeaderEpochRequestFilter.An invoker for OffsetForLeaderEpochResponseFilter.An invoker for ProduceRequestFilter.An invoker for ProduceResponseFilter.An invoker for PushTelemetryRequestFilter.An invoker for PushTelemetryResponseFilter.An invoker for ReadShareGroupStateRequestFilter.An invoker for ReadShareGroupStateResponseFilter.An invoker for ReadShareGroupStateSummaryRequestFilter.An invoker for ReadShareGroupStateSummaryResponseFilter.An invoker for RemoveRaftVoterRequestFilter.An invoker for RemoveRaftVoterResponseFilter.An invoker for RenewDelegationTokenRequestFilter.An invoker for RenewDelegationTokenResponseFilter.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.An invoker for SaslAuthenticateRequestFilter.An invoker for SaslAuthenticateResponseFilter.An invoker for SaslHandshakeRequestFilter.An invoker for SaslHandshakeResponseFilter.An invoker for ShareAcknowledgeRequestFilter.An invoker for ShareAcknowledgeResponseFilter.An invoker for ShareFetchRequestFilter.An invoker for ShareFetchResponseFilter.An invoker for ShareGroupDescribeRequestFilter.An invoker for ShareGroupDescribeResponseFilter.An invoker for ShareGroupHeartbeatRequestFilter.An invoker for ShareGroupHeartbeatResponseFilter.Invoker for Filters that implement any number of Specific Message interfaces (for exampleAlterConfigsResponseFilter.An invoker for StreamsGroupDescribeRequestFilter.An invoker for StreamsGroupDescribeResponseFilter.An invoker for StreamsGroupHeartbeatRequestFilter.An invoker for StreamsGroupHeartbeatResponseFilter.An invoker for SyncGroupRequestFilter.An invoker for SyncGroupResponseFilter.An invoker for TxnOffsetCommitRequestFilter.An invoker for TxnOffsetCommitResponseFilter.An invoker for UnregisterBrokerRequestFilter.An invoker for UnregisterBrokerResponseFilter.An invoker for UpdateFeaturesRequestFilter.An invoker for UpdateFeaturesResponseFilter.An invoker for UpdateRaftVoterRequestFilter.An invoker for UpdateRaftVoterResponseFilter.An invoker for VoteRequestFilter.An invoker for VoteResponseFilter.An invoker for WriteShareGroupStateRequestFilter.An invoker for WriteShareGroupStateResponseFilter.An invoker for WriteTxnMarkersRequestFilter.An invoker for WriteTxnMarkersResponseFilter.