Uses of Interface
io.kroxylicious.proxy.filter.RequestFilterResult

Packages that use RequestFilterResult
Package
Description
io.kroxylicious.proxy.filter
The protocol filter API.

  • Uses of RequestFilterResult in io.kroxylicious.proxy.filter

    Methods in io.kroxylicious.proxy.filter that return types with arguments of type RequestFilterResult
    Modifier and Type
    Method
    Description
    CloseOrTerminalStage<RequestFilterResult>
    RequestFilterResultBuilder.errorResponse(org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.protocol.ApiMessage requestMessage, org.apache.kafka.common.errors.ApiException apiException)
    Generate a short-circuit error response towards the client.
    CompletionStage<RequestFilterResult>
    FilterContext.forwardRequest(org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.protocol.ApiMessage request)
    Generates a completed filter results containing the given header and request.
    CompletionStage<RequestFilterResult>
    AddOffsetsToTxnRequestFilter.onAddOffsetsToTxnRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.AddOffsetsToTxnRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    AddPartitionsToTxnRequestFilter.onAddPartitionsToTxnRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.AddPartitionsToTxnRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    AddRaftVoterRequestFilter.onAddRaftVoterRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.AddRaftVoterRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    AllocateProducerIdsRequestFilter.onAllocateProducerIdsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.AllocateProducerIdsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    AlterClientQuotasRequestFilter.onAlterClientQuotasRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.AlterClientQuotasRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    AlterConfigsRequestFilter.onAlterConfigsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.AlterConfigsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    AlterPartitionReassignmentsRequestFilter.onAlterPartitionReassignmentsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.AlterPartitionReassignmentsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    AlterPartitionRequestFilter.onAlterPartitionRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.AlterPartitionRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    AlterReplicaLogDirsRequestFilter.onAlterReplicaLogDirsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.AlterReplicaLogDirsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    AlterShareGroupOffsetsRequestFilter.onAlterShareGroupOffsetsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.AlterShareGroupOffsetsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    AlterUserScramCredentialsRequestFilter.onAlterUserScramCredentialsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.AlterUserScramCredentialsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    ApiVersionsRequestFilter.onApiVersionsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.ApiVersionsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    AssignReplicasToDirsRequestFilter.onAssignReplicasToDirsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.AssignReplicasToDirsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    BeginQuorumEpochRequestFilter.onBeginQuorumEpochRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.BeginQuorumEpochRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    BrokerHeartbeatRequestFilter.onBrokerHeartbeatRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.BrokerHeartbeatRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    BrokerRegistrationRequestFilter.onBrokerRegistrationRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.BrokerRegistrationRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    ConsumerGroupDescribeRequestFilter.onConsumerGroupDescribeRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.ConsumerGroupDescribeRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    ConsumerGroupHeartbeatRequestFilter.onConsumerGroupHeartbeatRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.ConsumerGroupHeartbeatRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    ControllerRegistrationRequestFilter.onControllerRegistrationRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.ControllerRegistrationRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    CreateAclsRequestFilter.onCreateAclsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.CreateAclsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    CreateDelegationTokenRequestFilter.onCreateDelegationTokenRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.CreateDelegationTokenRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    CreatePartitionsRequestFilter.onCreatePartitionsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.CreatePartitionsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    CreateTopicsRequestFilter.onCreateTopicsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.CreateTopicsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    DeleteAclsRequestFilter.onDeleteAclsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.DeleteAclsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    DeleteGroupsRequestFilter.onDeleteGroupsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.DeleteGroupsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    DeleteRecordsRequestFilter.onDeleteRecordsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.DeleteRecordsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    DeleteShareGroupOffsetsRequestFilter.onDeleteShareGroupOffsetsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.DeleteShareGroupOffsetsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    DeleteShareGroupStateRequestFilter.onDeleteShareGroupStateRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.DeleteShareGroupStateRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    DeleteTopicsRequestFilter.onDeleteTopicsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.DeleteTopicsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    DescribeAclsRequestFilter.onDescribeAclsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.DescribeAclsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    DescribeClientQuotasRequestFilter.onDescribeClientQuotasRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.DescribeClientQuotasRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    DescribeClusterRequestFilter.onDescribeClusterRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.DescribeClusterRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    DescribeConfigsRequestFilter.onDescribeConfigsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.DescribeConfigsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    DescribeDelegationTokenRequestFilter.onDescribeDelegationTokenRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.DescribeDelegationTokenRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    DescribeGroupsRequestFilter.onDescribeGroupsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.DescribeGroupsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    DescribeLogDirsRequestFilter.onDescribeLogDirsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.DescribeLogDirsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    DescribeProducersRequestFilter.onDescribeProducersRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.DescribeProducersRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    DescribeQuorumRequestFilter.onDescribeQuorumRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.DescribeQuorumRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    DescribeShareGroupOffsetsRequestFilter.onDescribeShareGroupOffsetsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.DescribeShareGroupOffsetsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    DescribeTopicPartitionsRequestFilter.onDescribeTopicPartitionsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.DescribeTopicPartitionsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    DescribeTransactionsRequestFilter.onDescribeTransactionsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.DescribeTransactionsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    DescribeUserScramCredentialsRequestFilter.onDescribeUserScramCredentialsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.DescribeUserScramCredentialsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    ElectLeadersRequestFilter.onElectLeadersRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.ElectLeadersRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    EndQuorumEpochRequestFilter.onEndQuorumEpochRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.EndQuorumEpochRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    EndTxnRequestFilter.onEndTxnRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.EndTxnRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    EnvelopeRequestFilter.onEnvelopeRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.EnvelopeRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    ExpireDelegationTokenRequestFilter.onExpireDelegationTokenRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.ExpireDelegationTokenRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    FetchRequestFilter.onFetchRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.FetchRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    FetchSnapshotRequestFilter.onFetchSnapshotRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.FetchSnapshotRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    FindCoordinatorRequestFilter.onFindCoordinatorRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.FindCoordinatorRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    GetTelemetrySubscriptionsRequestFilter.onGetTelemetrySubscriptionsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.GetTelemetrySubscriptionsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    HeartbeatRequestFilter.onHeartbeatRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.HeartbeatRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    IncrementalAlterConfigsRequestFilter.onIncrementalAlterConfigsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.IncrementalAlterConfigsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    InitializeShareGroupStateRequestFilter.onInitializeShareGroupStateRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.InitializeShareGroupStateRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    InitProducerIdRequestFilter.onInitProducerIdRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.InitProducerIdRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    JoinGroupRequestFilter.onJoinGroupRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.JoinGroupRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    LeaveGroupRequestFilter.onLeaveGroupRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.LeaveGroupRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    ListConfigResourcesRequestFilter.onListConfigResourcesRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.ListConfigResourcesRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    ListGroupsRequestFilter.onListGroupsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.ListGroupsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    ListOffsetsRequestFilter.onListOffsetsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.ListOffsetsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    ListPartitionReassignmentsRequestFilter.onListPartitionReassignmentsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.ListPartitionReassignmentsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    ListTransactionsRequestFilter.onListTransactionsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.ListTransactionsRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    MetadataRequestFilter.onMetadataRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.MetadataRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    OffsetCommitRequestFilter.onOffsetCommitRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.OffsetCommitRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    OffsetDeleteRequestFilter.onOffsetDeleteRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.OffsetDeleteRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    OffsetFetchRequestFilter.onOffsetFetchRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.OffsetFetchRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    OffsetForLeaderEpochRequestFilter.onOffsetForLeaderEpochRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.OffsetForLeaderEpochRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    ProduceRequestFilter.onProduceRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.ProduceRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    PushTelemetryRequestFilter.onPushTelemetryRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.PushTelemetryRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    ReadShareGroupStateRequestFilter.onReadShareGroupStateRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.ReadShareGroupStateRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    ReadShareGroupStateSummaryRequestFilter.onReadShareGroupStateSummaryRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.ReadShareGroupStateSummaryRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    RemoveRaftVoterRequestFilter.onRemoveRaftVoterRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.RemoveRaftVoterRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    RenewDelegationTokenRequestFilter.onRenewDelegationTokenRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.RenewDelegationTokenRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    default CompletionStage<RequestFilterResult>
    RequestFilter.onRequest(org.apache.kafka.common.protocol.ApiKeys apiKey, short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.protocol.ApiMessage request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    default CompletionStage<RequestFilterResult>
    RequestFilter.onRequest(org.apache.kafka.common.protocol.ApiKeys apiKey, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.protocol.ApiMessage request, FilterContext context)
    Deprecated, for removal: This API element is subject to removal in a future version.
    implement RequestFilter.onRequest(ApiKeys, short, RequestHeaderData, ApiMessage, FilterContext) instead.
    CompletionStage<RequestFilterResult>
    SaslAuthenticateRequestFilter.onSaslAuthenticateRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.SaslAuthenticateRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    SaslHandshakeRequestFilter.onSaslHandshakeRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.SaslHandshakeRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    ShareAcknowledgeRequestFilter.onShareAcknowledgeRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.ShareAcknowledgeRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    ShareFetchRequestFilter.onShareFetchRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.ShareFetchRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    ShareGroupDescribeRequestFilter.onShareGroupDescribeRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.ShareGroupDescribeRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    ShareGroupHeartbeatRequestFilter.onShareGroupHeartbeatRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.ShareGroupHeartbeatRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    StreamsGroupDescribeRequestFilter.onStreamsGroupDescribeRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.StreamsGroupDescribeRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    StreamsGroupHeartbeatRequestFilter.onStreamsGroupHeartbeatRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.StreamsGroupHeartbeatRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    SyncGroupRequestFilter.onSyncGroupRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.SyncGroupRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    TxnOffsetCommitRequestFilter.onTxnOffsetCommitRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.TxnOffsetCommitRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    UnregisterBrokerRequestFilter.onUnregisterBrokerRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.UnregisterBrokerRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    UpdateFeaturesRequestFilter.onUpdateFeaturesRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.UpdateFeaturesRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    UpdateRaftVoterRequestFilter.onUpdateRaftVoterRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.UpdateRaftVoterRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    VoteRequestFilter.onVoteRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.VoteRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    WriteShareGroupStateRequestFilter.onWriteShareGroupStateRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.WriteShareGroupStateRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CompletionStage<RequestFilterResult>
    WriteTxnMarkersRequestFilter.onWriteTxnMarkersRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.WriteTxnMarkersRequestData request, FilterContext context)
    Handle the given header and request pair, returning the header and request pair to be passed to the next filter using the RequestFilterResult.
    CloseOrTerminalStage<RequestFilterResult>
    RequestFilterResultBuilder.shortCircuitResponse(org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.protocol.ApiMessage message)
    A short-circuit response towards the client.
    CloseOrTerminalStage<RequestFilterResult>
    RequestFilterResultBuilder.shortCircuitResponse(org.apache.kafka.common.protocol.ApiMessage message)
    A short-circuit response towards the client.