CCDAK Sample Practice Exam Questions 2026 Updated Verified
Exam Study Guide Free Practice Test LAST UPDATED CCDAK
The CCDAK exam mainly focuses on Kafka core concepts and API usage, including Kafka architecture, topics, partitions, replication, and the Kafka producer and consumer API. Kafka Connect and Kafka Streams API are two important components of the Kafka ecosystem, and candidates have to demonstrate their proficiency in these areas too. The Kafka Connect API is used for building connectors that transfer data between Kafka and other data sources, while the Kafka Streams library is used for stream processing in Kafka.
NEW QUESTION # 137
There are two consumers C1 and C2 belonging to the same group G subscribed to topics T1 and T2. Each of the topics has 3 partitions. How will the partitions be assigned to consumers with Partition Assigner being Round Robin Assigner?
- A. C1 will be assigned partitions 0 and 1 from T1 and T2, C2 will be assigned partition 2 from T1 and T2.
- B. Two consumers cannot read from two topics at the same time
- C. C1 will be assigned partitions 0 and 2 from T1 and partition 1 from T2. C2 will have partition 1 from T1 and partitions 0 and 2 from T2.
- D. All consumers will read from all partitions
Answer: C
Explanation:
The correct option is the only one where the two consumers share an equal number of partitions amongst the two topics of three partitions. An interesting article to read ishttps://medium.com/@anyili0928/what-i-have-learned-from-kafka-partition-assignment-strategy-799fdf15d3ab
NEW QUESTION # 138
A kafka topic has a replication factor of 3 and min.insync.replicas setting of 2. How many brokers can go down before a producer with acks=1 can't produce?
- A. 0
- B. 1
- C. 2
- D. 3
Answer: B
Explanation:
min.insync.replicas does not impact producers when acks=1 (only when acks=all)
NEW QUESTION # 139
Which type of system best describes Apache Kafka? (Choose 2.)
- A. FIFO
- B. Quorum based
- C. Distributed commit log
- D. Publish-subscribe messaging
- E. Leader-follower
Answer: C,D
NEW QUESTION # 140
In Kafka, what are Topics split into?
- A. Chunks
- B. Sub Topics
- C. Partitions
- D. Consumers
Answer: C
NEW QUESTION # 141
The rule "same key goes to the same partition" is true unless...
- A. the number of producer changes
- B. the number of partition changes
- C. the number of kafka broker changes
- D. the replication factor changes
Answer: B
Explanation:
Increasing the number of partition causes new messages keys to get hashed differently, and breaks the guarantee "same keys goes to the same partition". Kafka logs are immutable and the previous messages are not re-shuffled.
NEW QUESTION # 142
To allow consumers in a group to resume at the previously committed offset, I need to set the proper value for...
- A. auto.offset.resets
- B. enable.auto.commit
- C. value.deserializer
- D. group.id
Answer: D
Explanation:
Setting a group.id that's consistent across restarts will allow your consumers part of the same group to resume reading from where offsets were last committed for that group
NEW QUESTION # 143
When auto.create.topics.enable is set to true in Kafka configuration, what are the circumstances under which a Kafka broker automatically creates a topic? (select three)
- A. Consumer reads message from a topic
- B. Producer sends message to a topic
- C. Client requests metadata for a topic
- D. Client alters number of partitions of a topic
Answer: A,B,C
Explanation:
A kafka broker automatically creates a topic under the following circumstances- When a producer starts writing messages to the topic - When a consumer starts reading messages from the topic - When any client requests metadata for the topic
NEW QUESTION # 144
Which function does ZooKeeper offer in Kafka?
- A. Consumer group rebalancing
- B. Controller re-election
- C. Partition assignment
- D. Authentication
Answer: B
NEW QUESTION # 145
You are building a system for a retail store to sell products to customers Which dataset should be modeled as a GlobatKTable? (Choose 3.)
- A. Inventory of products at a warehouse e.g 100 items left
- B. All purchases at a retail store occurring in real time
- C. Customer profile information
- D. Log of payment transactions
- E. Catalog of products
Answer: A,D,E
NEW QUESTION # 146
What is a consequence of increasing the number of partitions in an existing Kafka topic?
- A. Existing data will be redistributed across the new number of partitions temporarily increasing cluster load.
- B. The acknowledgment process will increase latency for producers using acks=all.
- C. Consumers will need to process data from more partitions which will significantly increase consumer lag.
- D. Records with the same key could be located in different partitions.
Answer: C
Explanation:
Increasing partitions increasesparallelism, but also means:
* Consumers in a group may have to handlemore partitions, especially if the number of consumers is lower than the number of partitions.
* This can result inincreased lag, especially under high load.
FromKafka Topic Management Docs:
"Increasing the number of partitions increases consumer work, and if consumers can't keep up, lag can accumulate."
* A is false:existing data is not redistributed.
* B is false:records with the same key always map to the same partitionbased on hash.
* D is not directly impacted by the partition count.
Reference:Kafka Topic Management > Adding Partitions
NEW QUESTION # 147
A customer has many consumer applications that process messages from a Kafka topic. Each consumer application can only process 50 MB/s. Your customer wants to achieve a target throughput of 1 GB/s. What is the minimum number of partitions will you suggest to the customer for that particular topic?
- A. 0
- B. 1
- C. 2
- D. 3
Answer: B
Explanation:
each consumer can process only 50 MB/s, so we need at least 20 consumers consuming one partition so that 50 * 20 = 1000 MB target is achieved.
NEW QUESTION # 148
To import data from external databases, I should use
- A. Kafka Connect Source
- B. Kafka Streams
- C. Kafka Connect Sink
- D. Confluent REST Proxy
Answer: A
Explanation:
Kafka Connect Sink is used to export data from Kafka to external databases and Kafka Connect Source is used to import from external databases into Kafka.
NEW QUESTION # 149
Your application is consuming from a topic with one consumer group.
The number of running consumers is equal to the number of partitions.
Application logs show that some consumers are leaving the consumer group during peak time, triggering a rebalance. You also notice that your application is processing many duplicates.
You need to stop consumers from leaving the consumer group.
What should you do?
- A. Reduce max.poll.records property.
- B. Add more consumer instances.
- C. Increase session.timeout.ms property.
- D. Split consumers in different consumer groups.
Answer: C
Explanation:
If the consumer fails to send heartbeats in time (due to being slow under load), it is considereddead, causing a rebalance. Increasing session.timeout.ms gives the consumermore time to process messages and send heartbeats, preventing premature removal.
FromKafka Docs > Heartbeats and Failures:
"If the consumer does not send a heartbeat in session.timeout.ms, it is considered dead and the group coordinator will trigger a rebalance." Reducing max.poll.records mightslow consumption further. More consumers won't help since each partition already has a dedicated consumer.
Reference:Apache Kafka Consumer Configs > session.timeout.ms
NEW QUESTION # 150
A topic has three replicas and you set min.insync.replicas to 2. If two out of three replicas are not available, what happens when a produce request with acks=all is sent to broker?
- A. Produce request will block till one of the two unavailable partition is available again.
- B. Produce request is honored with single in-sync replica
- C. NotEnoughReplicasException will be returned
Answer: C
Explanation:
With this configuration, a single in-sync replica becomes read-only. Produce request will receive NotEnoughReplicasException.
NEW QUESTION # 151
What is the default port that the KSQL server listens on?
- A. 0
- B. 1
- C. 2
- D. 3
Answer: B
Explanation:
Default port of KSQL server is 8088
NEW QUESTION # 152
This schema excerpt is an example of which schema format?
package com.mycorp.mynamespace;
message SampleRecord {
int32 Stock = 1;
double Price = 2;
string Product_Name = 3;
}
- A. YAML
- B. Protobuf
- C. Avro
- D. JSON Schema
Answer: B
Explanation:
This syntax is a clear match toProtocol Buffers (Protobuf). It defines a schema with fields, types, and tags, which is a format supported by Kafka when usingProtobuf-based schema registry serialization.
FromConfluent Schema Registry Docs:
"Kafka supports Protobuf serialization, where schemas are written in .proto files and include fields with tags."
* int32, double, and string are standard Protobuf types.
* Avro uses JSON-style schema.
* JSON Schema uses JSON object structure, not .proto.
* YAML is unrelated.
Reference:Confluent Schema Registry for Protobuf
NEW QUESTION # 153
You are sending messages with keys to a topic. To increase throughput, you decide to increase the number of partitions of the topic. Select all that apply.
- A. New records with the same key will get written to the partition where old records with that key were written
- B. Old records will stay in their partitions
- C. New records may get written to a different partition
- D. All the existing records will get rebalanced among the partitions to balance load
Answer: B,C
Explanation:
Increasing the number of partition causes new messages keys to get hashed differently, and breaks the guarantee "same keys goes to the same partition". Kafka logs are immutable and the previous messages are not re-shuffled
NEW QUESTION # 154
There are 3 producers writing to a topic with 5 partitions. There are 5 consumers consuming from the topic. How many Controllers will be present in the cluster?
- A. 0
- B. 1
- C. 2
- D. 3
Answer: C
Explanation:
There is only one controller in a cluster at all times.
NEW QUESTION # 155
In Kafka Streams, by what value are internal topics prefixed by?
- A. kafka-streams-
- B. group.id
- C. application.id
- D. tasks-<number>
Answer: C
Explanation:
In Kafka Streams, the application.id is also the underlying group.id for your consumers, and the prefix for all internal topics (repartition and state)
NEW QUESTION # 156
Which Kafka CLI should you use to consume from a topic?
- A. kafka-topics
- B. kafka-consumer-groups
- C. kafka-console
- D. kafka-console-consumer
Answer: D
Explanation:
Examplekafka-console-consumer --bootstrap-server 127.0.0.1:9092 --topic test --from-beginning
NEW QUESTION # 157
What is the disadvantage of request/response communication?
- A. Reliability
- B. Coupling
- C. Scalability
- D. Cost
Answer: B
Explanation:
Point-to-point (request-response) style will couple client to the server.
NEW QUESTION # 158
Suppose you have 6 brokers and you decide to create a topic with 10 partitions and a replication factor of 3.
The brokers 0 and 1 are on rack A, the brokers 2 and 3 are on rack B, and the brokers 4 and 5 are on rack C.
If the leader for partition 0 is on broker 4, and the first replica is on broker 2, which broker can host the last replica? (select two)
- A. 0
- B. 1
- C. 2
- D. 3
- E. 4
- F. 5
Answer: D,E
Explanation:
When you create a new topic, partitions replicas are spreads across racks to maintain availability. Hence, the Rack A, which currently does not hold the topic partition, will be selected for the last replica
NEW QUESTION # 159
......
The New CCDAK 2026 Updated Verified Study Guides & Best Courses: https://examtests.passcollection.com/CCDAK-valid-vce-dumps.html
