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

Packages that use ResponseFilterResult

Package	Description
io.kroxylicious.proxy.filter	The protocol filter API.

Uses of ResponseFilterResult in io.kroxylicious.proxy.filter

Methods in io.kroxylicious.proxy.filter that return types with arguments of type ResponseFilterResult

Modifier and Type	Method	Description
CompletionStage<ResponseFilterResult>	FilterContext.forwardResponse(org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.protocol.ApiMessage response)	Generates a completed filter results containing the given header and response.
CompletionStage<ResponseFilterResult>	AddOffsetsToTxnResponseFilter.onAddOffsetsToTxnResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.AddOffsetsToTxnResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	AddPartitionsToTxnResponseFilter.onAddPartitionsToTxnResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.AddPartitionsToTxnResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	AddRaftVoterResponseFilter.onAddRaftVoterResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.AddRaftVoterResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	AllocateProducerIdsResponseFilter.onAllocateProducerIdsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.AllocateProducerIdsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	AlterClientQuotasResponseFilter.onAlterClientQuotasResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.AlterClientQuotasResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	AlterConfigsResponseFilter.onAlterConfigsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.AlterConfigsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	AlterPartitionReassignmentsResponseFilter.onAlterPartitionReassignmentsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.AlterPartitionReassignmentsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	AlterPartitionResponseFilter.onAlterPartitionResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.AlterPartitionResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	AlterReplicaLogDirsResponseFilter.onAlterReplicaLogDirsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.AlterReplicaLogDirsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	AlterShareGroupOffsetsResponseFilter.onAlterShareGroupOffsetsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.AlterShareGroupOffsetsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	AlterUserScramCredentialsResponseFilter.onAlterUserScramCredentialsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.AlterUserScramCredentialsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	ApiVersionsResponseFilter.onApiVersionsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.ApiVersionsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	AssignReplicasToDirsResponseFilter.onAssignReplicasToDirsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.AssignReplicasToDirsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	BeginQuorumEpochResponseFilter.onBeginQuorumEpochResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.BeginQuorumEpochResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	BrokerHeartbeatResponseFilter.onBrokerHeartbeatResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.BrokerHeartbeatResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	BrokerRegistrationResponseFilter.onBrokerRegistrationResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.BrokerRegistrationResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	ConsumerGroupDescribeResponseFilter.onConsumerGroupDescribeResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.ConsumerGroupDescribeResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	ConsumerGroupHeartbeatResponseFilter.onConsumerGroupHeartbeatResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.ConsumerGroupHeartbeatResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	ControllerRegistrationResponseFilter.onControllerRegistrationResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.ControllerRegistrationResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	CreateAclsResponseFilter.onCreateAclsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.CreateAclsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	CreateDelegationTokenResponseFilter.onCreateDelegationTokenResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.CreateDelegationTokenResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	CreatePartitionsResponseFilter.onCreatePartitionsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.CreatePartitionsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	CreateTopicsResponseFilter.onCreateTopicsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.CreateTopicsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	DeleteAclsResponseFilter.onDeleteAclsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.DeleteAclsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	DeleteGroupsResponseFilter.onDeleteGroupsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.DeleteGroupsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	DeleteRecordsResponseFilter.onDeleteRecordsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.DeleteRecordsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	DeleteShareGroupOffsetsResponseFilter.onDeleteShareGroupOffsetsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.DeleteShareGroupOffsetsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	DeleteShareGroupStateResponseFilter.onDeleteShareGroupStateResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.DeleteShareGroupStateResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	DeleteTopicsResponseFilter.onDeleteTopicsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.DeleteTopicsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	DescribeAclsResponseFilter.onDescribeAclsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.DescribeAclsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	DescribeClientQuotasResponseFilter.onDescribeClientQuotasResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.DescribeClientQuotasResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	DescribeClusterResponseFilter.onDescribeClusterResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.DescribeClusterResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	DescribeConfigsResponseFilter.onDescribeConfigsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.DescribeConfigsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	DescribeDelegationTokenResponseFilter.onDescribeDelegationTokenResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.DescribeDelegationTokenResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	DescribeGroupsResponseFilter.onDescribeGroupsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.DescribeGroupsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	DescribeLogDirsResponseFilter.onDescribeLogDirsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.DescribeLogDirsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	DescribeProducersResponseFilter.onDescribeProducersResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.DescribeProducersResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	DescribeQuorumResponseFilter.onDescribeQuorumResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.DescribeQuorumResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	DescribeShareGroupOffsetsResponseFilter.onDescribeShareGroupOffsetsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.DescribeShareGroupOffsetsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	DescribeTopicPartitionsResponseFilter.onDescribeTopicPartitionsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.DescribeTopicPartitionsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	DescribeTransactionsResponseFilter.onDescribeTransactionsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.DescribeTransactionsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	DescribeUserScramCredentialsResponseFilter.onDescribeUserScramCredentialsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.DescribeUserScramCredentialsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	ElectLeadersResponseFilter.onElectLeadersResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.ElectLeadersResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	EndQuorumEpochResponseFilter.onEndQuorumEpochResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.EndQuorumEpochResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	EndTxnResponseFilter.onEndTxnResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.EndTxnResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	EnvelopeResponseFilter.onEnvelopeResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.EnvelopeResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	ExpireDelegationTokenResponseFilter.onExpireDelegationTokenResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.ExpireDelegationTokenResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	FetchResponseFilter.onFetchResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.FetchResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	FetchSnapshotResponseFilter.onFetchSnapshotResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.FetchSnapshotResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	FindCoordinatorResponseFilter.onFindCoordinatorResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.FindCoordinatorResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	GetTelemetrySubscriptionsResponseFilter.onGetTelemetrySubscriptionsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.GetTelemetrySubscriptionsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	HeartbeatResponseFilter.onHeartbeatResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.HeartbeatResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	IncrementalAlterConfigsResponseFilter.onIncrementalAlterConfigsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.IncrementalAlterConfigsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	InitializeShareGroupStateResponseFilter.onInitializeShareGroupStateResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.InitializeShareGroupStateResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	InitProducerIdResponseFilter.onInitProducerIdResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.InitProducerIdResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	JoinGroupResponseFilter.onJoinGroupResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.JoinGroupResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	LeaveGroupResponseFilter.onLeaveGroupResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.LeaveGroupResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	ListConfigResourcesResponseFilter.onListConfigResourcesResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.ListConfigResourcesResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	ListGroupsResponseFilter.onListGroupsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.ListGroupsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	ListOffsetsResponseFilter.onListOffsetsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.ListOffsetsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	ListPartitionReassignmentsResponseFilter.onListPartitionReassignmentsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.ListPartitionReassignmentsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	ListTransactionsResponseFilter.onListTransactionsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.ListTransactionsResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	MetadataResponseFilter.onMetadataResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.MetadataResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	OffsetCommitResponseFilter.onOffsetCommitResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.OffsetCommitResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	OffsetDeleteResponseFilter.onOffsetDeleteResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.OffsetDeleteResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	OffsetFetchResponseFilter.onOffsetFetchResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.OffsetFetchResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	OffsetForLeaderEpochResponseFilter.onOffsetForLeaderEpochResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.OffsetForLeaderEpochResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	ProduceResponseFilter.onProduceResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.ProduceResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	PushTelemetryResponseFilter.onPushTelemetryResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.PushTelemetryResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	ReadShareGroupStateResponseFilter.onReadShareGroupStateResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.ReadShareGroupStateResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	ReadShareGroupStateSummaryResponseFilter.onReadShareGroupStateSummaryResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.ReadShareGroupStateSummaryResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	RemoveRaftVoterResponseFilter.onRemoveRaftVoterResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.RemoveRaftVoterResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	RenewDelegationTokenResponseFilter.onRenewDelegationTokenResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.RenewDelegationTokenResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
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 given header and response pair, returning the header and response pair 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. implement ResponseFilter.onResponse(ApiKeys, short, ResponseHeaderData, ApiMessage, FilterContext) instead.
CompletionStage<ResponseFilterResult>	SaslAuthenticateResponseFilter.onSaslAuthenticateResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.SaslAuthenticateResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	SaslHandshakeResponseFilter.onSaslHandshakeResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.SaslHandshakeResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	ShareAcknowledgeResponseFilter.onShareAcknowledgeResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.ShareAcknowledgeResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	ShareFetchResponseFilter.onShareFetchResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.ShareFetchResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	ShareGroupDescribeResponseFilter.onShareGroupDescribeResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.ShareGroupDescribeResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	ShareGroupHeartbeatResponseFilter.onShareGroupHeartbeatResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.ShareGroupHeartbeatResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	StreamsGroupDescribeResponseFilter.onStreamsGroupDescribeResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.StreamsGroupDescribeResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	StreamsGroupHeartbeatResponseFilter.onStreamsGroupHeartbeatResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.StreamsGroupHeartbeatResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	SyncGroupResponseFilter.onSyncGroupResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.SyncGroupResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	TxnOffsetCommitResponseFilter.onTxnOffsetCommitResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.TxnOffsetCommitResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	UnregisterBrokerResponseFilter.onUnregisterBrokerResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.UnregisterBrokerResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	UpdateFeaturesResponseFilter.onUpdateFeaturesResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.UpdateFeaturesResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	UpdateRaftVoterResponseFilter.onUpdateRaftVoterResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.UpdateRaftVoterResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	VoteResponseFilter.onVoteResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.VoteResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	WriteShareGroupStateResponseFilter.onWriteShareGroupStateResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.WriteShareGroupStateResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.
CompletionStage<ResponseFilterResult>	WriteTxnMarkersResponseFilter.onWriteTxnMarkersResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.WriteTxnMarkersResponseData response, FilterContext context)	Handle the given header and response pair, returning the header and response pair to be passed to the next filter using the ResponseFilterResult.