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

Class ApiVersionsDowngradeFilter

java.lang.Object

io.kroxylicious.proxy.internal.filter.impl.ApiVersionsDowngradeFilter

All Implemented Interfaces:

io.kroxylicious.proxy.filter.ApiVersionsRequestFilter, io.kroxylicious.proxy.filter.Filter

public class ApiVersionsDowngradeFilter
extends Object
implements io.kroxylicious.proxy.filter.ApiVersionsRequestFilter

Constructor Summary

Constructors

Constructor	Description
ApiVersionsDowngradeFilter(ApiVersionsServiceImpl apiVersionsService)

Method Summary

Modifier and Type	Method	Description
static DecodedRequestFrame<org.apache.kafka.common.message.ApiVersionsRequestData>	downgradeApiVersionsFrame(int correlationId)
CompletionStage<io.kroxylicious.proxy.filter.RequestFilterResult>	onApiVersionsRequest(short apiVersion, org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.message.ApiVersionsRequestData request, 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.ApiVersionsRequestFilter

shouldHandleApiVersionsRequest

Constructor Details

ApiVersionsDowngradeFilter

public ApiVersionsDowngradeFilter(ApiVersionsServiceImpl apiVersionsService)

Method Details

downgradeApiVersionsFrame

public static DecodedRequestFrame<org.apache.kafka.common.message.ApiVersionsRequestData> downgradeApiVersionsFrame(int correlationId)

onApiVersionsRequest

public CompletionStage<io.kroxylicious.proxy.filter.RequestFilterResult> onApiVersionsRequest(short apiVersion,
 org.apache.kafka.common.message.RequestHeaderData header,
 org.apache.kafka.common.message.ApiVersionsRequestData request,
 io.kroxylicious.proxy.filter.FilterContext context)

Specified by:

onApiVersionsRequest in interface io.kroxylicious.proxy.filter.ApiVersionsRequestFilter