org.apache.kafka.common.protocol
Class Protocol
java.lang.Object
org.apache.kafka.common.protocol.Protocol
public class Protocol
- extends java.lang.Object
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
REQUEST_HEADER
public static Schema REQUEST_HEADER
RESPONSE_HEADER
public static Schema RESPONSE_HEADER
METADATA_REQUEST_V0
public static Schema METADATA_REQUEST_V0
BROKER
public static Schema BROKER
PARTITION_METADATA_V0
public static Schema PARTITION_METADATA_V0
TOPIC_METADATA_V0
public static Schema TOPIC_METADATA_V0
METADATA_RESPONSE_V0
public static Schema METADATA_RESPONSE_V0
METADATA_REQUEST
public static Schema[] METADATA_REQUEST
METADATA_RESPONSE
public static Schema[] METADATA_RESPONSE
TOPIC_PRODUCE_DATA_V0
public static Schema TOPIC_PRODUCE_DATA_V0
PRODUCE_REQUEST_V0
public static Schema PRODUCE_REQUEST_V0
PRODUCE_RESPONSE_V0
public static Schema PRODUCE_RESPONSE_V0
PRODUCE_REQUEST
public static Schema[] PRODUCE_REQUEST
PRODUCE_RESPONSE
public static Schema[] PRODUCE_RESPONSE
OFFSET_COMMIT_REQUEST_PARTITION_V0
public static Schema OFFSET_COMMIT_REQUEST_PARTITION_V0
OFFSET_COMMIT_REQUEST_TOPIC_V0
public static Schema OFFSET_COMMIT_REQUEST_TOPIC_V0
OFFSET_COMMIT_REQUEST_V0
public static Schema OFFSET_COMMIT_REQUEST_V0
OFFSET_COMMIT_REQUEST_V1
public static Schema OFFSET_COMMIT_REQUEST_V1
OFFSET_COMMIT_RESPONSE_PARTITION_V0
public static Schema OFFSET_COMMIT_RESPONSE_PARTITION_V0
OFFSET_COMMIT_RESPONSE_TOPIC_V0
public static Schema OFFSET_COMMIT_RESPONSE_TOPIC_V0
OFFSET_COMMIT_RESPONSE_V0
public static Schema OFFSET_COMMIT_RESPONSE_V0
OFFSET_COMMIT_REQUEST
public static Schema[] OFFSET_COMMIT_REQUEST
OFFSET_COMMIT_RESPONSE
public static Schema[] OFFSET_COMMIT_RESPONSE
OFFSET_FETCH_REQUEST_PARTITION_V0
public static Schema OFFSET_FETCH_REQUEST_PARTITION_V0
OFFSET_FETCH_REQUEST_TOPIC_V0
public static Schema OFFSET_FETCH_REQUEST_TOPIC_V0
OFFSET_FETCH_REQUEST_V0
public static Schema OFFSET_FETCH_REQUEST_V0
OFFSET_FETCH_RESPONSE_PARTITION_V0
public static Schema OFFSET_FETCH_RESPONSE_PARTITION_V0
OFFSET_FETCH_RESPONSE_TOPIC_V0
public static Schema OFFSET_FETCH_RESPONSE_TOPIC_V0
OFFSET_FETCH_RESPONSE_V0
public static Schema OFFSET_FETCH_RESPONSE_V0
OFFSET_FETCH_REQUEST
public static Schema[] OFFSET_FETCH_REQUEST
OFFSET_FETCH_RESPONSE
public static Schema[] OFFSET_FETCH_RESPONSE
LIST_OFFSET_REQUEST_PARTITION_V0
public static Schema LIST_OFFSET_REQUEST_PARTITION_V0
LIST_OFFSET_REQUEST_TOPIC_V0
public static Schema LIST_OFFSET_REQUEST_TOPIC_V0
LIST_OFFSET_REQUEST_V0
public static Schema LIST_OFFSET_REQUEST_V0
LIST_OFFSET_RESPONSE_PARTITION_V0
public static Schema LIST_OFFSET_RESPONSE_PARTITION_V0
LIST_OFFSET_RESPONSE_TOPIC_V0
public static Schema LIST_OFFSET_RESPONSE_TOPIC_V0
LIST_OFFSET_RESPONSE_V0
public static Schema LIST_OFFSET_RESPONSE_V0
LIST_OFFSET_REQUEST
public static Schema[] LIST_OFFSET_REQUEST
LIST_OFFSET_RESPONSE
public static Schema[] LIST_OFFSET_RESPONSE
FETCH_REQUEST_PARTITION_V0
public static Schema FETCH_REQUEST_PARTITION_V0
FETCH_REQUEST_TOPIC_V0
public static Schema FETCH_REQUEST_TOPIC_V0
FETCH_REQUEST_V0
public static Schema FETCH_REQUEST_V0
FETCH_RESPONSE_PARTITION_V0
public static Schema FETCH_RESPONSE_PARTITION_V0
FETCH_RESPONSE_TOPIC_V0
public static Schema FETCH_RESPONSE_TOPIC_V0
FETCH_RESPONSE_V0
public static Schema FETCH_RESPONSE_V0
FETCH_REQUEST
public static Schema[] FETCH_REQUEST
FETCH_RESPONSE
public static Schema[] FETCH_RESPONSE
CONSUMER_METADATA_REQUEST_V0
public static Schema CONSUMER_METADATA_REQUEST_V0
CONSUMER_METADATA_RESPONSE_V0
public static Schema CONSUMER_METADATA_RESPONSE_V0
CONSUMER_METADATA_REQUEST
public static Schema[] CONSUMER_METADATA_REQUEST
CONSUMER_METADATA_RESPONSE
public static Schema[] CONSUMER_METADATA_RESPONSE
JOIN_GROUP_REQUEST_V0
public static Schema JOIN_GROUP_REQUEST_V0
JOIN_GROUP_RESPONSE_TOPIC_V0
public static Schema JOIN_GROUP_RESPONSE_TOPIC_V0
JOIN_GROUP_RESPONSE_V0
public static Schema JOIN_GROUP_RESPONSE_V0
JOIN_GROUP_REQUEST
public static Schema[] JOIN_GROUP_REQUEST
JOIN_GROUP_RESPONSE
public static Schema[] JOIN_GROUP_RESPONSE
HEARTBEAT_REQUEST_V0
public static Schema HEARTBEAT_REQUEST_V0
HEARTBEAT_RESPONSE_V0
public static Schema HEARTBEAT_RESPONSE_V0
HEARTBEAT_REQUEST
public static Schema[] HEARTBEAT_REQUEST
HEARTBEAT_RESPONSE
public static Schema[] HEARTBEAT_RESPONSE
REQUESTS
public static Schema[][] REQUESTS
RESPONSES
public static Schema[][] RESPONSES
CURR_VERSION
public static short[] CURR_VERSION
Protocol
public Protocol()