DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
Discussion thread: https://lists.apache.org/thread/t4h273md03vzcbzk4r3bn86km8rnym66
Vote thread: https://lists.apache.org/thread/j0ol8tk2fdyk0bk6x859yw5dtjh8h1xc
JIRA: Jira server ASF JIRA serverId 5aa69414-a9e9-3523-82ec-879b028fb15b key KAFKA-20167
...
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 | N/A |
| close() (new) [2] | Consumer REMAIN | Consumer REMAIN | Consumer DEFAULT (LEAVE) | Consumer DEFAULT (REMAIN) |
| close(REMAIN_IN_GROUP) (current) | Consumer REMAIN | Consumer REMAIN | Consumer LEAVE | N/A |
| close(REMAIN_IN_GROUP) (new) | Consumer REMAIN | Consumer REMAIN | Consumer REMAIN | Consumer REMAIN |
| close(LEAVE_GROUP) (current) | Consumer LEAVE | Consumer LEAVE | Consumer LEAVE | N/A |
| 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)
...