Package io.kroxylicious.proxy.config

Class SniHostIdentifiesNodeIdentificationStrategy

java.lang.Object

io.kroxylicious.proxy.config.SniHostIdentifiesNodeIdentificationStrategy

All Implemented Interfaces:

NodeIdentificationStrategyFactory

public class SniHostIdentifiesNodeIdentificationStrategy
extends Object
implements NodeIdentificationStrategyFactory

A NodeIdentificationStrategy implementation that binds to a single, shared, port for bootstrap and all brokers. SNI information is used to route the connection to the correct target.
The following configuration is required:

• bootstrapAddress a HostPort defining the host and port of the bootstrap address.
• $advertisedBrokerAddressPattern must be set. This property contains an address pattern used to advertise broker addresses. It is addresses made from this pattern that are returned to the kafka client in the Metadata response so must be resolvable by the client. Optionally these properties can specify a port which will be advertised to the clients. Two patterns ar supported:
  • $(nodeId) - which interpolates the node id into the address.
  • $(virtualClusterName) - which interpolates the virtual cluster name into the address.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SniHostIdentifiesNodeIdentificationStrategy.UnresolvedHostException

Constructor Summary

Constructors

Constructor	Description
SniHostIdentifiesNodeIdentificationStrategy(String bootstrapAddress, String advertisedBrokerAddressPattern)

Method Summary

Modifier and Type	Method	Description
NodeIdentificationStrategy	buildStrategy(String clusterName)
boolean	equals(Object obj)
String	getAdvertisedBrokerAddressPattern()
int	getAdvertisedPort()
String	getBootstrapAddress()
String	getBootstrapAddressPattern()
int	getBootstrapPort()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

SniHostIdentifiesNodeIdentificationStrategy

public SniHostIdentifiesNodeIdentificationStrategy(String bootstrapAddress,
 String advertisedBrokerAddressPattern)

Method Details

getBootstrapAddressPattern

public String getBootstrapAddressPattern()

getAdvertisedPort

public int getAdvertisedPort()

getBootstrapPort

public int getBootstrapPort()

getBootstrapAddress

public String getBootstrapAddress()

getAdvertisedBrokerAddressPattern

public String getAdvertisedBrokerAddressPattern()

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

buildStrategy

public NodeIdentificationStrategy buildStrategy(String clusterName)

Specified by:

buildStrategy in interface NodeIdentificationStrategyFactory