org.apache.kafka.common.requests
Class RequestHeader
java.lang.Object
org.apache.kafka.common.requests.AbstractRequestResponse
org.apache.kafka.common.requests.RequestHeader
public class RequestHeader
- extends AbstractRequestResponse
The header for a request in the Kafka protocol
Methods inherited from class java.lang.Object |
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
RequestHeader
public RequestHeader(Struct header)
RequestHeader
public RequestHeader(short apiKey,
java.lang.String client,
int correlation)
RequestHeader
public RequestHeader(short apiKey,
short version,
java.lang.String client,
int correlation)
apiKey
public short apiKey()
apiVersion
public short apiVersion()
clientId
public java.lang.String clientId()
correlationId
public int correlationId()
parse
public static RequestHeader parse(java.nio.ByteBuffer buffer)