Class CloudProxyTlvParser

java.lang.Object

io.confluent.kafka.common.network.CloudProxyTlvParser

All Implemented Interfaces:

org.apache.kafka.common.Configurable, org.apache.kafka.common.network.ProxyTlvParser

public class CloudProxyTlvParser
extends Object
implements org.apache.kafka.common.network.ProxyTlvParser

Field Summary

Fields

Modifier and Type	Field	Description
static final org.apache.kafka.common.network.ProxyTlvType	NETWORK_CONTEXT_TLV_TYPE
static final int	PP2_SUBTYPE_CFLTV2_NETWORK_CONTEXT
static final int	PP2_TYPE_CFLTV2

Constructor Summary

Constructors

Constructor	Description
CloudProxyTlvParser()

Method Summary

Modifier and Type	Method	Description
void	configure(Map<String,?> configs)
Optional<org.apache.kafka.common.network.ProxyTlv>	parse(org.slf4j.Logger log, int tlvType, byte[] bytes)

Methods inherited from class java.lang.Object

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

Field Details

PP2_TYPE_CFLTV2

public static final int PP2_TYPE_CFLTV2

See Also:

• Constant Field Values

PP2_SUBTYPE_CFLTV2_NETWORK_CONTEXT

public static final int PP2_SUBTYPE_CFLTV2_NETWORK_CONTEXT

See Also:

• Constant Field Values

NETWORK_CONTEXT_TLV_TYPE

public static final org.apache.kafka.common.network.ProxyTlvType NETWORK_CONTEXT_TLV_TYPE

Constructor Details

CloudProxyTlvParser

public CloudProxyTlvParser()

Method Details

configure

public void configure(Map<String,?> configs)

Specified by:

configure in interface org.apache.kafka.common.Configurable

parse

public Optional<org.apache.kafka.common.network.ProxyTlv> parse(org.slf4j.Logger log,
 int tlvType,
 byte[] bytes)

Specified by:

parse in interface org.apache.kafka.common.network.ProxyTlvParser