CCDAK Apache Kafka Practice Test 2026 - Free Apache Kafka Practice Questions and Certification Guide

Assign() is about fixing which partitions a consumer will read from. In Kafka, there are two ways to tell a consumer what data to process: subscribing to topics, which uses the consumer group protocol to automatically assign partitions, and manually assigning partitions with assign(). When you call assign() and pass a set of TopicPartition objects, you bind this consumer to those specific partitions and it will only consume from them. This bypasses the dynamic partition rebalancing that happens with subscribe(). It’s not about committing offsets automatically, closing the consumer, or creating a new consumer group—the latter two are done by other methods/properties. Therefore, the statement that best describes assign() is that it assigns partitions for the consumer to read from.