Module membership 

Streams group membership: the StreamsGroupHeartbeat lifecycle and the assignments.

The heartbeat client is a Kafka network client and exists only on native targets. The assignment value types build everywhere, so an embedder on wasm32-unknown-unknown can describe the tasks its own membership logic assigns.

Structs

StreamsAssignment

The active tasks, the standby tasks, and the warmup tasks assigned to this member.

StreamsJoinRetryBackoff

Positive, whole-millisecond delay between Client Streams initial join retries.

StreamsLeaveHeartbeatTimeout

Positive, whole-millisecond deadline for the final leave heartbeat.

StreamsMembership

A live streams-group membership. Construct via StreamsMembership::builder.

StreamsRebalanceTimeout

Positive, whole-millisecond rebalance timeout representable on the Kafka wire.

TaskAssignment

One assigned task and the source topic-partitions it processes.

TaskOffsetTracker

A tracker to share task restored and end offsets with the coordinator loop.

TopicPartition

A concrete topic-partition a task consumes.

Enums

StreamsEvent

An event emitted by the membership heartbeat loop.

StreamsStatus

A non-ready status that the coordinator reports, using the KIP-1071 status codes.

Constants

DEFAULT_STREAMS_JOIN_RETRY_BACKOFF

Default delay between Client Streams initial join retries.

DEFAULT_STREAMS_LEAVE_HEARTBEAT_TIMEOUT

Default deadline for the final Client Streams leave heartbeat.

DEFAULT_STREAMS_REBALANCE_TIMEOUT

Default Client Streams rebalance timeout.

Traits

SchemaPrewarm

Hook that runs once at membership start to resolve schema ids before processing. SchemaCache implements it under the schema-serde feature.