public class ClusterLinkInterceptor
extends java.lang.Object
implements org.apache.kafka.clients.ClientInterceptor, org.apache.kafka.common.Configurable
Constructor and Description |
---|
ClusterLinkInterceptor() |
Modifier and Type | Method and Description |
---|---|
void |
configure(java.util.Map<java.lang.String,?> configs) |
org.apache.kafka.common.protocol.types.Struct |
parseResponse(java.nio.ByteBuffer responseBuffer,
org.apache.kafka.common.requests.RequestHeader requestHeader) |
org.apache.kafka.common.network.Send |
toSend(org.apache.kafka.common.requests.RequestHeader requestHeader,
org.apache.kafka.common.requests.AbstractRequest requestBody,
java.lang.String destination) |
public void configure(java.util.Map<java.lang.String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
public org.apache.kafka.common.network.Send toSend(org.apache.kafka.common.requests.RequestHeader requestHeader, org.apache.kafka.common.requests.AbstractRequest requestBody, java.lang.String destination)
toSend
in interface org.apache.kafka.clients.ClientInterceptor
public org.apache.kafka.common.protocol.types.Struct parseResponse(java.nio.ByteBuffer responseBuffer, org.apache.kafka.common.requests.RequestHeader requestHeader)
parseResponse
in interface org.apache.kafka.clients.ClientInterceptor