DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
Currently, the Streams Protocol implementation in StreamsGroupHeartbeatManager does not honor REMAIN_IN_GROUP. This gap must be addressed as part of this KIP to ensure the option functions correctly end-to-end under KIP-1071: Streams Rebalance Protocol#Compatibility,DeprecationandMigrationPlan.
Behavior Matrix
| Streams CloseOption | Classic Protocol (Dynamic Member) | Classic Protocol (Static Member) | Streams Protocol (Dynamic Member) | Streams Protocol (Static Member) |
|---|---|---|---|---|
| close() (current) [1] | Consumer REMAIN | Consumer REMAIN | Consumer LEAVE |
| Consumer LEAVE | ||||
| close() (new) [2] | Consumer REMAIN | Consumer REMAIN | Consumer DEFAULT (LEAVE) | Consumer DEFAULT (REMAIN) |
| close(REMAIN_IN_GROUP) (current) | Consumer REMAIN | Consumer REMAIN | Consumer LEAVE |
| Consumer LEAVE | ||||
| close(REMAIN_IN_GROUP) (new) | Consumer REMAIN | Consumer REMAIN | Consumer REMAIN | Consumer REMAIN |
| close(LEAVE_GROUP) (current) | Consumer LEAVE | Consumer LEAVE | Consumer LEAVE |
| Consumer LEAVE | ||||
| close(LEAVE_GROUP) (new) | Consumer LEAVE | Consumer LEAVE | Consumer LEAVE | Consumer LEAVE |
Legend:
close()(current) internally delegates toclose(REMAIN_IN_GROUP)close()(new) internally delegates toclose(DEFAULT)
...