Package io.kroxylicious.proxy.internal.codec

Interface DecodePredicate

public interface DecodePredicate
Encapsulates decisions about whether requests and responses should be fully deserialized into POJOs, or passed through as byte buffers with minimal deserialization. The actual decision can depend on which filters are in use, which can depend on who the authorized user or, or which back-end cluster they're connected to.

  • Method Details

    • forFilters

      static DecodePredicate forFilters(List<FilterAndInvoker> filterAndInvokers)

    • shouldDecodeRequest

      boolean shouldDecodeRequest(org.apache.kafka.common.protocol.ApiKeys apiKey, short apiVersion)

    • shouldDecodeResponse

      boolean shouldDecodeResponse(org.apache.kafka.common.protocol.ApiKeys apiKey, short apiVersion)