View Full Confluent CCDAK Exam Dumps and Practice Test Dumps

 

Question 61

Which Kafka concept determines how many consumers can process a topic in parallel?

1. Record timestamp
2. Replication factor
3. Partition count
4. Retention period

Correct Answer: 3

Explanation:

Kafka partitions provide the fundamental unit of parallel consumption within a consumer group. A partition is assigned to at most one active consumer within the same group at a time, so the number of partitions establishes an upper bound on consumer parallelism for that group. Increasing consumer instances beyond the available partitions does not create additional partition-level processing concurrency. Replication factor serves durability, while retention controls data lifetime. CCDAK architects should therefore consider expected consumer concurrency when selecting partition counts, while also accounting for ordering requirements, throughput, storage distribution, and future scaling needs.

Question 62

Which Kafka protocol feature lets clients discover broker and partition information?

1. Metadata request
2. Commit request
3. Produce response
4. Fetch session

Correct Answer: 1

Explanation:

Kafka clients use metadata requests to discover information about topics, partitions, leaders, and available brokers. Producers need this information to determine where records should be sent, while consumers use broker and partition metadata to locate the appropriate leaders. Metadata can change when partitions are reassigned or leadership moves between brokers, so clients periodically refresh their knowledge. CCDAK architects should understand metadata flow because client connectivity, broker discovery, leader changes, and cluster topology all depend on accurate metadata. Metadata requests are part of the native Kafka client-broker protocol rather than an application-level data payload mechanism.

Question 63

Which Kafka feature allows a consumer to reset its position when no valid committed offset exists?

1. Consumer heartbeat
2. Auto partitioning
3. Offset reset policy
4. Producer fencing

Correct Answer: 3

Explanation:

Kafka consumers use an offset reset policy to determine where consumption should begin when no valid committed offset is available. Common policies include starting from the earliest available record or starting from the latest records. The choice can significantly affect application behavior after a new consumer group is created or when previously committed offsets are unavailable. CCDAK architects should select the policy according to replay and recovery requirements. A system that needs historical processing may require an earlier starting position, whereas an application interested only in newly arriving events may prefer the latest available position.

Question 64

Which consumer setting selects the starting position when offsets are unavailable?

1. isolation.level
2. auto.offset.reset
3. fetch.max.bytes
4. client.rack

Correct Answer: 2

Explanation:

The auto.offset.reset consumer configuration specifies what a consumer should do when its current offset is unavailable or invalid. Typical choices allow consumption from the earliest available record, the latest record, or an error depending on the configured behavior. This setting does not normally override a valid committed offset. CCDAK architects should understand this distinction because changing auto.offset.reset does not automatically rewind an active consumer with a valid committed position. Replay requirements may instead require explicit offset management or a new consumer group.

Question 65

What does consumer lag measure?

1. Broker disk capacity
2. Producer throughput
3. Schema age
4. Processing position behind log end

Correct Answer: 4

Explanation:

Consumer lag represents how far a consumer group’s processing position is behind the available records at the end of a partition. It is an important operational indicator because sustained lag can indicate insufficient consumer capacity, slow downstream processing, broker issues, or traffic spikes. Lag is generally evaluated per partition and aggregated across a consumer group. It should not be interpreted solely as an application failure because temporary bursts can naturally create lag that later decreases. CCDAK architects should monitor lag trends alongside processing latency, throughput, partition distribution, and downstream dependencies.

Question 66

Which consumer mechanism periodically signals that a group member is still active?

1. Heartbeats
2. Fetch batches
3. Offset resets
4. Metadata refreshes

Correct Answer: 1

Explanation:

Consumer heartbeats allow a group member to communicate its liveness to the Kafka group coordinator. Regular heartbeats help Kafka determine whether a consumer remains an active member of its group. If expected heartbeats stop for long enough, the coordinator can remove the member and initiate a rebalance. Heartbeat behavior is distinct from application polling, although consumer configuration connects several timing parameters. CCDAK architects should tune heartbeat and session-related settings according to network conditions and processing behavior so healthy consumers are not unnecessarily removed while failed consumers can still be detected promptly.

Question 67

Which consumer setting controls how long the broker waits before returning a fetch response?

1. max.poll.records
2. fetch.max.wait.ms
3. session.timeout.ms
4. auto.offset.reset

Correct Answer: 2

Explanation:

fetch.max.wait.ms controls the maximum amount of time the broker may wait for sufficient data to become available before responding to a consumer fetch request, subject to other fetch conditions. This setting works with fetch.min.bytes, which specifies a minimum amount of data the consumer would like to receive. Together, they can influence request efficiency and latency. CCDAK architects should tune fetch behavior according to traffic patterns, record sizes, and latency objectives. Excessive waiting can affect responsiveness, while overly aggressive fetching can increase request overhead.

Question 68

Which consumer configuration limits the maximum bytes returned from a broker in one fetch?

1. fetch.max.bytes
2. receive.buffer.bytes
3. max.poll.records
4. fetch.min.bytes

Correct Answer: 1

Explanation:

fetch.max.bytes limits the amount of data the consumer will attempt to receive in a fetch response from the broker. It influences how much data can be transferred during a fetch cycle and therefore affects memory usage, throughput, and processing behavior. max.poll.records limits the number of records returned to application code, which is a different constraint. CCDAK architects should consider both byte-based and record-based limits when tuning consumers. Record size, partition count, downstream processing speed, and network capacity all influence appropriate consumer fetch settings.

Question 69

Which Kafka feature supports reading from multiple partitions within one consumer?

1. Partition assignment
2. Schema registration
3. Log compaction
4. Broker election

Correct Answer: 1

Explanation:

Partition assignment determines which partitions are assigned to each consumer in a group. A single consumer can receive multiple partitions when the group’s membership and partition count require that distribution. Assignment is coordinated when consumers join, leave, or otherwise trigger group changes. This allows Kafka to distribute a topic’s workload across consumer instances while maintaining partition-level ownership. CCDAK architects should consider assignment behavior when sizing consumer applications because an uneven distribution can affect processing throughput and create partition-specific lag even when aggregate consumer capacity appears sufficient.

Question 70

Which consumer property identifies the application’s consumer group?

1. client.id
2. group.id
3. bootstrap.servers
4. group.instance.id

Correct Answer: 2

Explanation:

The group.id property identifies the consumer group to which a Kafka consumer belongs. Consumers using the same group ID cooperate to process partitions, while consumers with different group IDs independently receive records from the same topic. This distinction makes consumer groups useful for implementing multiple independent applications over the same event stream. client.id is primarily an identifier for client-related monitoring, while bootstrap.servers specifies initial broker connection addresses. CCDAK architects should design group IDs carefully because they define consumption relationships and offset ownership.

Question 71

Which consumer property provides a stable identity for static group membership?

1. group.instance.id
2. client.rack
3. client.id
4. fetch.min.bytes

Correct Answer: 1

Explanation:

group.instance.id provides a stable identity for a consumer instance and enables static membership. Static membership can reduce unnecessary group rebalances when a known consumer temporarily disconnects and then returns within the relevant session period. This can be valuable for applications where frequent restarts or temporary network interruptions would otherwise cause disruptive reassignments. It is different from the consumer group’s group.id, which identifies the group itself. CCDAK architects should evaluate static membership for workloads where preserving assignments during brief disruptions can improve stability and reduce rebalance overhead.

Question 72

Which partition assignment strategy distributes partitions evenly across consumers?

1. Range assignor
2. Round-robin assignor
3. Sticky assignor
4. Cooperative sticky assignor

Correct Answer: 2

Explanation:

The round-robin assignor distributes partitions across consumers in a rotating sequence, generally aiming for an even distribution when subscriptions align appropriately. Assignment strategies differ in how they balance partitions, preserve existing ownership, and react to membership changes. Sticky strategies emphasize retaining assignments where practical, while cooperative sticky behavior can reduce disruptive reassignment during group changes. CCDAK architects should select an assignment strategy based on workload structure, subscription patterns, partition distribution, and rebalance behavior rather than assuming one strategy is universally suitable.

Question 73

Which assignment strategy is designed to reduce unnecessary partition movement?

1. Range assignor
2. Round-robin assignor
3. Sticky assignor
4. Random assignor

Correct Answer: 3

Explanation:

The sticky assignor attempts to balance partitions while preserving existing assignments where possible. Retaining assignments can reduce unnecessary partition movement during consumer group changes and therefore help limit disruption to processing. This is especially useful when consumers maintain local state or when reassignment has a measurable operational cost. Other assignment strategies use different balancing approaches and may move more partitions during a rebalance. CCDAK architects should consider state locality, rebalance frequency, subscription patterns, and workload distribution when deciding how consumer partitions should be assigned.

Question 74

Which Kafka consumer behavior can pause fetching without leaving the group?

1. Consumer pause
2. Topic deletion
3. Replica election
4. Offset compaction

Correct Answer: 1

Explanation:

A Kafka consumer can pause assigned partitions using the consumer API, temporarily stopping record fetching for those partitions while remaining a member of the consumer group. This can be useful when an application needs to apply backpressure, wait for a downstream dependency, or prioritize certain partitions. Pausing is different from leaving the group or committing offsets. CCDAK architects can use pause and resume behavior as part of flow-control strategies, but they must still ensure that processing and polling behavior remains compatible with consumer timing configurations.

Question 75

Which Kafka consumer operation manually advances a partition position?

1. seek
2. subscribe
3. wakeup
4. assignment

Correct Answer: 1

Explanation:

The consumer seek operation manually changes the position from which records will be fetched for a specific partition. This capability is useful for replaying records, skipping known problematic data, or implementing specialized recovery workflows. Seeking does not automatically mean that the new position has been committed for future consumer sessions. Applications must separately manage offset commits when persistent progress needs to reflect the new position. CCDAK architects should use manual seeking carefully because incorrect positioning can cause records to be replayed or skipped unintentionally.

Question 76

Which Kafka consumer method requests records from assigned partitions?

1. poll()
2. commitSync()
3. seek()
4. pause()

Correct Answer: 1

Explanation:

The consumer poll() method retrieves available records from partitions assigned to the consumer and also participates in the consumer’s normal group interaction. Applications typically call poll() repeatedly while processing records. The polling pattern is important because consumer group membership and processing progress depend on continued interaction with Kafka. commitSync() commits offsets, seek() changes a partition’s local position, and pause() temporarily stops fetching from selected partitions. CCDAK architects should design the polling loop carefully, especially when processing can take substantial time.

Question 77

Which Kafka API allows an application to inspect available cluster resources programmatically?

1. Admin API
2. Producer API
3. Consumer API
4. Streams DSL

Correct Answer: 1

Explanation:

The Kafka Admin API provides programmatic access to administrative metadata and resource-management operations. Applications can use it to inspect topics, partitions, configurations, and other Kafka resources depending on the operation required. This capability is useful for automation, provisioning, diagnostics, and platform-management services. Producer and Consumer APIs focus on event data movement, while the Streams DSL is designed for stream-processing logic. CCDAK architects can use the Admin API when building automated infrastructure workflows that need to integrate Kafka administration into broader deployment or operational systems.

Question 78

Which Kafka mechanism assigns a partition leader among replicas?

1. Consumer coordinator
2. Controller
3. Schema Registry
4. Connect worker

Correct Answer: 2

Explanation:

The Kafka controller coordinates partition leadership changes and other cluster metadata operations. When a partition leader becomes unavailable, controller processes help select an appropriate replica according to Kafka’s leadership rules and available replica state. This allows the cluster to recover from broker failures while maintaining partition availability when suitable replicas remain available. Consumer coordinators manage consumer group membership, while Schema Registry and Connect workers serve different platform functions. CCDAK architects should understand controller responsibilities because leadership changes can directly influence client request routing and cluster availability.

Question 79

Which Kafka configuration enables broker-to-broker data compression for replication?

1. compression.type
2. inter.broker.protocol.version
3. replica.fetch.response.max.bytes
4. message.downconversion.enable

Correct Answer: 1

Explanation:

The compression.type configuration influences the compression behavior of Kafka log data and can affect how records are stored and transferred within the broker architecture. Compression reduces the amount of data moved across networks and written to storage, although it requires CPU resources. The actual behavior also depends on producer-side compression and Kafka’s handling of record batches. CCDAK architects should evaluate compression as part of an overall resource trade-off involving network bandwidth, disk capacity, CPU availability, and message characteristics rather than viewing it only as a storage optimization.

Question 80

Which Kafka feature allows topic data to be copied between clusters?

1. Kafka Streams
2. Cluster Linking
3. Schema Registry
4. ksqlDB

Correct Answer: 2

Explanation:

Confluent Cluster Linking allows data and metadata relationships to be established between Kafka clusters, supporting scenarios such as disaster recovery, migration, and multi-cluster architectures. It can reduce the need to build and operate a separate replication pipeline for certain cross-cluster use cases. Kafka Streams processes data, Schema Registry manages schemas, and ksqlDB provides stream processing. CCDAK architects should evaluate Cluster Linking according to network topology, cluster ownership, security requirements, recovery objectives, and the desired relationship between source and destination environments.