Versions Compared

Key

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

...

Code Block
languagescala
titleGroupCoordinator.scala
def handleJoinGroup(...)

def handleSyncGroup(...)

where we shall enforce the group size capping rules upon requests.

Proposed Changes


We shall add a config called group.max.size on the coordinator side.

...

The default value 1_000_000 proposed here is based on a rough size estimation of member metadata (100B120B), so the max allowed memory usage per group is 100B 120B * 1_000_000 = 100 MB which should be sufficient large number for of 5X~10X for most use cases I know. Welcome Further discussion on this number.is welcomed on defining the default value!

Implementation wise we shall block registration of new member once a group reaches its capacity, and define a new error type:

...