Package org.apache.kafka.clients.consumer.internals

Class ConsumerProtocol

java.lang.Object

org.apache.kafka.clients.consumer.internals.ConsumerProtocol

public class ConsumerProtocol
extends Object

ConsumerProtocol contains the schemas for consumer subscriptions and assignments for use with Kafka's generalized group management protocol. The current implementation assumes that future versions will not break compatibility. When it encounters a newer version, it parses it using the current format. This basically means that new versions cannot remove or reorder any of the existing fields.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	PROTOCOL_TYPE

Constructor Summary

Constructors

Constructor	Description
ConsumerProtocol()

Method Summary

Modifier and Type	Method	Description
static ConsumerPartitionAssignor.Assignment	deserializeAssignment(ByteBuffer buffer)
static ConsumerPartitionAssignor.Assignment	deserializeAssignment(ByteBuffer buffer, short version)
static ConsumerPartitionAssignor.Subscription	deserializeSubscription(ByteBuffer buffer)
static ConsumerPartitionAssignor.Subscription	deserializeSubscription(ByteBuffer buffer, short version)
static short	deserializeVersion(ByteBuffer buffer)
static ByteBuffer	serializeAssignment(ConsumerPartitionAssignor.Assignment assignment)
static ByteBuffer	serializeAssignment(ConsumerPartitionAssignor.Assignment assignment, short version)
static ByteBuffer	serializeSubscription(ConsumerPartitionAssignor.Subscription subscription)
static ByteBuffer	serializeSubscription(ConsumerPartitionAssignor.Subscription subscription, short version)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

PROTOCOL_TYPE

public static final String PROTOCOL_TYPE

See Also:

• Constant Field Values

Constructor Details

ConsumerProtocol

public ConsumerProtocol()

Method Details

deserializeVersion

public static short deserializeVersion(ByteBuffer buffer)

serializeSubscription

public static ByteBuffer serializeSubscription(ConsumerPartitionAssignor.Subscription subscription)

serializeSubscription

public static ByteBuffer serializeSubscription(ConsumerPartitionAssignor.Subscription subscription,
 short version)

deserializeSubscription

public static ConsumerPartitionAssignor.Subscription deserializeSubscription(ByteBuffer buffer,
 short version)

deserializeSubscription

public static ConsumerPartitionAssignor.Subscription deserializeSubscription(ByteBuffer buffer)

serializeAssignment

public static ByteBuffer serializeAssignment(ConsumerPartitionAssignor.Assignment assignment)

serializeAssignment

public static ByteBuffer serializeAssignment(ConsumerPartitionAssignor.Assignment assignment,
 short version)

deserializeAssignment

public static ConsumerPartitionAssignor.Assignment deserializeAssignment(ByteBuffer buffer,
 short version)

deserializeAssignment

public static ConsumerPartitionAssignor.Assignment deserializeAssignment(ByteBuffer buffer)