Package io.kroxylicious.proxy.internal.filter.impl

Class ApiVersionsIntersectFilter

java.lang.Object

io.kroxylicious.proxy.internal.filter.impl.ApiVersionsIntersectFilter

All Implemented Interfaces:

io.kroxylicious.proxy.filter.ApiVersionsResponseFilter, io.kroxylicious.proxy.filter.Filter

public class ApiVersionsIntersectFilter
extends Object
implements io.kroxylicious.proxy.filter.ApiVersionsResponseFilter

Changes an API_VERSIONS response so that a client sees the intersection of supported version ranges for each API key. This is an intrinsic part of correctly acting as a proxy.

Constructor Summary

Constructors

Constructor	Description
ApiVersionsIntersectFilter(ApiVersionsServiceImpl service)

Method Summary

Modifier and Type	Method	Description
CompletionStage<io.kroxylicious.proxy.filter.ResponseFilterResult>	onApiVersionsResponse(short apiVersion, org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.message.ApiVersionsResponseData data, io.kroxylicious.proxy.filter.FilterContext context)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.kroxylicious.proxy.filter.ApiVersionsResponseFilter

shouldHandleApiVersionsResponse

Constructor Details

ApiVersionsIntersectFilter

public ApiVersionsIntersectFilter(ApiVersionsServiceImpl service)

Method Details

onApiVersionsResponse

public CompletionStage<io.kroxylicious.proxy.filter.ResponseFilterResult> onApiVersionsResponse(short apiVersion,
 org.apache.kafka.common.message.ResponseHeaderData header,
 org.apache.kafka.common.message.ApiVersionsResponseData data,
 io.kroxylicious.proxy.filter.FilterContext context)

Specified by:

onApiVersionsResponse in interface io.kroxylicious.proxy.filter.ApiVersionsResponseFilter