public class ClusterLinkInterceptor extends Object implements org.apache.kafka.clients.ClientInterceptor, org.apache.kafka.common.Configurable
Modifier and Type | Field and Description |
---|---|
static String |
DEST_METRICS_GROUP |
static String |
SOURCE_METRICS_GROUP |
Constructor and Description |
---|
ClusterLinkInterceptor() |
Modifier and Type | Method and Description |
---|---|
void |
configure(Map<String,?> configs) |
void |
configureMetrics(org.apache.kafka.common.metrics.Metrics metrics) |
org.apache.kafka.common.requests.AbstractResponse |
parseResponse(ByteBuffer responseBuffer,
org.apache.kafka.common.requests.RequestHeader requestHeader,
long requestSendTimeMs,
long responseReceiveTimeMs) |
org.apache.kafka.common.network.Send |
toSend(org.apache.kafka.common.requests.RequestHeader requestHeader,
org.apache.kafka.common.requests.AbstractRequest requestBody,
long requestSendTimeMs) |
public static final String DEST_METRICS_GROUP
public static final String SOURCE_METRICS_GROUP
public void configure(Map<String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public void configureMetrics(org.apache.kafka.common.metrics.Metrics metrics)
configureMetrics
in interface org.apache.kafka.clients.ClientInterceptor
public org.apache.kafka.common.network.Send toSend(org.apache.kafka.common.requests.RequestHeader requestHeader, org.apache.kafka.common.requests.AbstractRequest requestBody, long requestSendTimeMs)
toSend
in interface org.apache.kafka.clients.ClientInterceptor
public org.apache.kafka.common.requests.AbstractResponse parseResponse(ByteBuffer responseBuffer, org.apache.kafka.common.requests.RequestHeader requestHeader, long requestSendTimeMs, long responseReceiveTimeMs)
parseResponse
in interface org.apache.kafka.clients.ClientInterceptor