DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
| Code Block | ||
|---|---|---|
| ||
{ "name": "TopologyDescriptionId", "type": "uuid", "versions": "N+",
"nullableVersions": "N+", "default": "null",
"about": "When non-null, the client should push its current topology description tagged with this id via UpdateStreamsGroupTopologyDescription. Null when no push is requested." } |
The broker mints a fresh TopologyDescriptionId on group creation and on every topology epoch bump and persists it on the streams group record. After each heartbeat from a non-STALE_TOPOLOGY member, the broker calls plugin.requiresTopologyPush(requestContext, groupId, topologyDescriptionId) with the current id; if the plugin returns true, the broker includes that id in the heartbeat response, otherwise the field is omitted.
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
{"name": "IncludeTopologyDescription", "type": "bool", "versions": "N+", "default": "false",
"about": "Whether to include the full topology description from the topology description plugin in the response." } |
A
...
client
...
that
...
negotiates
...
an
...
older
...
version
...
is
...
handled
...
unchanged
...
by
...
any
...
broker.
...
The
...
flag
...
may
...
only
...
be
...
set
...
when
...
version
...
N
...
or
...
later
...
is
...
negotiated.
StreamsGroupDescribeResponse Change
...