Versions Compared

Key

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

...

NameTypeDefaultDoc
group.protocolenumgeneric

A flag which indicates if the new protocol should be used or not. It could be: generic or consumer

group.remote.assignorstringuniformThe server side assignor to use. It cannot be used in conjunction with group.local.assignor.
group.local.assignorslistemptyThe list of client side (local) assignors. It cannot be used in conjunction with group.remote.assignor.

Streams New Assignor and Assignment Metadata

TODO

name

type

note

processId

uuid / static

Inherited. In the future we may also remove this field when one instance only use one consumer

userEndPoint

bytes / static

Inherited

clientTags

map / static

Inherited

errorCode

int8 / dynamic

Inherited and enhanced. Communicate rebalance reasons, possible values:

  • None
  • Shutdown
  • Warm-up ready
  • Warm-up failed
  • Requested by coordinator
  • Topology changed
  • [more?]

topologyHash

uuid / dynamic

Only updatable when errorCode is not “none”.

taskLag

array / dynamic

Only updatable when errorCode is not “none”.

...