Module consumer_partition_assignor 

Data holders for the consumer partition assignor protocol.

Translated from the Subscription and Assignment nested data classes of org.apache.kafka.clients.consumer.ConsumerPartitionAssignor.

Only the two data holders are in scope here: they are consumed by ConsumerProtocol for (de)serializing member subscriptions/assignments, which the admin group-describe path relies on. The ConsumerPartitionAssignor trait itself and the client-side assignors (RangeAssignor, StickyAssignor, …) are out of scope for Milestone 8/11 (KIP-848 uses server-side assignment) — see consumer-threading.md §20.

Structs

Assignment

A consumer member’s assignment.

Subscription

A consumer member’s subscription.

SubscriptionOptions

The parameters of Java’s widest Subscription constructor (Subscription(List, ByteBuffer, List, int, Optional<String>), ConsumerPartitionAssignor.java:113).

SubscriptionOptionsBuilder

Fluent builder for SubscriptionOptions.

Constants

DEFAULT_GENERATION

The default generation id used when a subscription carries no generation.