Package io.kroxylicious.proxy.internal.util

Class RequestHeaderTagger

java.lang.Object

io.kroxylicious.proxy.internal.util.RequestHeaderTagger

public class RequestHeaderTagger
extends Object

Utility for tagging message headers with internal tags. Such tags should not be propagated to the upstream broker.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	RequestHeaderTagger.Tag

Constructor Summary

Constructors

Constructor	Description
RequestHeaderTagger()

Method Summary

Modifier and Type	Method	Description
static boolean	containsTag(org.apache.kafka.common.message.RequestHeaderData headerData, RequestHeaderTagger.Tag tag)
static void	removeTags(org.apache.kafka.common.message.RequestHeaderData header)
static void	tag(org.apache.kafka.common.message.RequestHeaderData headerData, RequestHeaderTagger.Tag tag)

Methods inherited from class java.lang.Object

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

Constructor Details

RequestHeaderTagger

public RequestHeaderTagger()

Method Details

removeTags

public static void removeTags(org.apache.kafka.common.message.RequestHeaderData header)

tag

public static void tag(org.apache.kafka.common.message.RequestHeaderData headerData,
 RequestHeaderTagger.Tag tag)

containsTag

public static boolean containsTag(org.apache.kafka.common.message.RequestHeaderData headerData,
 RequestHeaderTagger.Tag tag)