SubscriptionInfo
is…FIXME
SubscriptionInfo
uses 4
for the latest supported subscription version.
SubscriptionInfo decode(final ByteBuffer data)
decode
…FIXME
Note
|
decode is used when…FIXME
|
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.
|
static void decodeTasks(
final SubscriptionInfo subscriptionInfo,
final ByteBuffer data)
decodeTasks
…FIXME
Note
|
decodeTasks is used when…FIXME
|
ByteBuffer encodeVersionFour()
encodeVersionFour
…FIXME
Note
|
encodeVersionFour is used exclusively when SubscriptionInfo is requested to encode (for the metadata version as 4 ).
|
ByteBuffer encodeVersionThree()
encodeVersionThree
…FIXME
Note
|
encodeVersionThree is used when…FIXME
|
ByteBuffer encodeVersionTwo()
encodeVersionTwo
…FIXME
Note
|
encodeVersionTwo is used when…FIXME
|
ByteBuffer encodeVersionOne()
encodeVersionOne
…FIXME
Note
|
encodeVersionOne is used when…FIXME
|
ByteBuffer encode()
encode
…FIXME
Note
|
encode is used exclusively when StreamsPartitionAssignor is requested to subscription.
|