Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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

...