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