Package io.kroxylicious.proxy.internal.codec
@ReturnValuesAreNonnullByDefault
@DefaultAnnotationForParameters(edu.umd.cs.findbugs.annotations.NonNull.class)
@DefaultAnnotation(edu.umd.cs.findbugs.annotations.NonNull.class)
package io.kroxylicious.proxy.internal.codec
-
ClassDescriptionDecodes Kafka Readable into an ApiMessageAn implementation of Kafka's Readable and Writable abstraction in terms of a Netty ByteBuf.Manages correlation ids for a single connection (across the proxy) between a single client and a single broker.A record for which responses should be decoded, together with their API key and version.Encapsulates decisions about whether requests and responses should be fully deserialized into POJOs, or passed through as byte buffers with minimal deserialization.Callback invoked by the
KafkaMessageEncoderandKafkaMessageDecoderon encode or decode of each message.