SubscriptionInfo

SubscriptionInfo is…​FIXME

SubscriptionInfo uses 4 for the latest supported subscription version.

decode Method

SubscriptionInfo decode(final ByteBuffer data)

decode…​FIXME

Note
 decode is used when…​FIXME

encodeTasks Method

void encodeTasks(
  final ByteBuffer buf,
  final Collection<TaskId> taskIds)

encodeTasks…​FIXME

Note
 encodeTasks is used when SubscriptionInfo is requested to encodeVersionOne, encodeVersionTwo, encodeVersionThree, and encodeVersionFour.

decodeTasks Factory Method

static void decodeTasks(
  final SubscriptionInfo subscriptionInfo,
  final ByteBuffer data)

decodeTasks…​FIXME

Note
 decodeTasks is used when…​FIXME

encodeVersionFour Internal Method

ByteBuffer encodeVersionFour()

encodeVersionFour…​FIXME

Note
 encodeVersionFour is used exclusively when SubscriptionInfo is requested to encode (for the metadata version as 4).

encodeVersionThree Internal Method

ByteBuffer encodeVersionThree()

encodeVersionThree…​FIXME

Note
 encodeVersionThree is used when…​FIXME

encodeVersionTwo Internal Method

ByteBuffer encodeVersionTwo()

encodeVersionTwo…​FIXME

Note
 encodeVersionTwo is used when…​FIXME

encodeVersionOne Internal Method

ByteBuffer encodeVersionOne()

encodeVersionOne…​FIXME

Note
 encodeVersionOne is used when…​FIXME

encode Method

ByteBuffer encode()

encode…​FIXME

Note
 encode is used exclusively when StreamsPartitionAssignor is requested to subscription.

results matching ""

    No results matching ""