...
Code Block |
---|
ClientTag => Key Value Key => BytesShort Value => Bytes |
Key
of the ClientTag
struct will be encoded in a deterministic way based on task.assignment.rack.awareness
configuration. For instance, if we have task.assignment.rack.awareness:
zone,cluster
, zone
will be encoded as 0 and cluster
as 1.
Kafka Streams's Task Assignor will make a decision on how to distribute standby tasks over the available clients based on encoded clientTags
within the subscription info and configured task.assignment.rack.awareness
...