Pass Confluent CCAAK Exam in First Attempt Guaranteed [Jan-2026]
Exam Sure Pass Confluent Certification with CCAAK exam questions
NEW QUESTION # 16
You have a Kafka cluster with topics t1 and t2. In the output below, topic t2 shows Partition 1 with a leader "-1".
What is the most likely reason for this?
...
$ kafka-topics --zookeeper localhost:2181 --describe --topic t1
Topic:t1 PartitionCount 1 ReplicationFactor 1 Configs:
Topic: t1 Partition: 0 Leader: 0 Replicas: 0 Isr: 0
$ kafka-topics --zookeeper localhost:2181 --describe --topic t2
Topic:t2 PartitionCount 2 ReplicationFactor 1 Configs:
Topic: t2 Partition: 0 Leader: 0 Replicas: 0 Isr: 0
Topic: t2 Partition: 1 Leader: -1 Replicas: 1 Isr:
- A. Broker 1 failed.
- B. Broker 1 has another partition clashing with the same name.
- C. Compression has been enabled on Broker 1.
- D. Leader shows "-1" while the log cleaner thread runs on Broker 1.
Answer: A
Explanation:
A Leader of -1 indicates that no broker is currently the leader for that partition. This usually happens when the only replica for that partition is unavailable, often due to the associated broker (in this case, Broker 1) failing or being offline. Kafka cannot elect a leader if no replica is in the in-sync replica (ISR) list, which leads to leader = -1.
NEW QUESTION # 17
What are benefits to gracefully shutting down brokers? (Choose two.)
- A. It will balance the partitions across brokers before restarting.
- B. It will migrate any partitions the server is the leader for to other replicas prior to shutting down.
- C. It will automatically re-elect leaders on restart.
- D. It will sync all its logs to disk to avoid needing to do any log recovery when it restarts.
Answer: B,D
Explanation:
A graceful shutdown ensures that logs are flushed to disk, minimizing recovery time during restart.
Kafka performs controlled leader migration during a graceful shutdown to avoid disruption and ensure availability.
NEW QUESTION # 18
A broker in the Kafka cluster is currently acting as the Controller.
Which statement is correct?
- A. All consumers are allowed to fetch messages only from this server.
- B. It is given precedence for replication to and from replica followers.
- C. It can have topic partitions.
- D. It is responsible for sending leader information to all producers.
Answer: C
Explanation:
The Controller broker is a regular broker that also takes on additional responsibilities for managing cluster metadata, such as leader elections and partition assignments. It still hosts topic partitions and participates in replication like any other broker.
NEW QUESTION # 19
Which ksqlDB statement produces data that is persisted into a Kafka topic?
- A. SELECT (Push Query)
- B. SELECT (Pull Query)
- C. CREATE TABLE
- D. INSERT VALUES
Answer: D
Explanation:
INSERT VALUES is used to write data directly into a Kafka topic through a ksqlDB stream or table. This data is persisted.
NEW QUESTION # 20
What is the correct permission check sequence for Kafka ACLs?
What is the correct permission check sequence for Kafka ACLs?
- A. Allow ACL -> Deny ACL -> Super Users -> Deny
- B. Deny ACL -> Deny -> Allow ACL -> Super Users
- C. Super Users -> Allow ACL -> Deny ACL-> Deny
- D. Super Users -> Deny ACL -> Allow ACL -> Deny
Answer: C
Explanation:
Kafka checks permissions in the following sequence:
1. Super Users: If the user is a super user (defined via super.users), access is granted immediately.
2. Allow ACL: If there is a matching Allow ACL, Kafka proceeds to the next step.
3. Deny ACL: If there is a matching Deny ACL, access is denied (even if an Allow exists).
4. Deny: If no matching ACLs are found, access is denied by default.
This order ensures that super users bypass ACLs, denials override allows, and default is deny.
NEW QUESTION # 21
Which out-of-the-box Kafka Authorizer implementation uses ZooKeeper?
- A. LDAP
- B. Ranger
- C. RBAC
- D. ACLs
Answer: D
Explanation:
Kafka's built-in ACL (Access Control List) authorizer stores and manages permissions using ZooKeeper by default. This implementation controls access at the resource level (topics, consumer groups, etc.).
NEW QUESTION # 22
You have a cluster with a topic t1 that already has uncompressed messages. A new Producer starts sending messages to t1 with compression enabled.
Which condition would allow this?
- A. Never, because topic t1 already has uncompressed messages.
- B. Only if the new Producer disables batching.
- C. Only if Kafka is also enabled for encryption.
- D. If the new Producer is configured to use compression.
Answer: D
Explanation:
Kafka allows mixed compression formats within the same topic and even the same partition. Each message batch includes metadata indicating whether and how it is compressed. Therefore, a new producer can send compressed messages to a topic that already contains uncompressed messages, as long as it is configured with a compression codec (e.g., compression.type=gzip, snappy, etc.).
NEW QUESTION # 23
Multiple clients are sharing a Kafka cluster.
As an administrator, how would you ensure that Kafka resources are distributed fairly to all clients?
- A. Quotas
- B. Rebalancing
- C. Consumer Groups
- D. ACLs
Answer: A
Explanation:
Kafka quotas allow administrators to control and limit the rate of data production and consumption per client (producer/consumer), ensuring fair use of broker resources among multiple clients.
NEW QUESTION # 24
If the Controller detects the failure of a broker that was the leader for some partitions, which actions will be taken? (Choose two.)
- A. The Controller waits for a new leader to be nominated by ZooKeeper.
- B. The Controller sends the new leader and ISR list changes to all producers and consumers.
- C. The Controller sends the new leader and ISR list changes to all brokers.
- D. The Controller persists the new leader and ISR list to ZooKeeper.
Answer: C,D
Explanation:
The Controller updates ZooKeeper with the new leader and in-sync replica (ISR) information to maintain metadata consistency.
Brokers need this information to correctly route client requests and continue replication.
NEW QUESTION # 25
Which valid security protocols are included for broker listeners? (Choose three.)
- A. SASL
- B. PLAINTEXT
- C. SASL_SSL
- D. SSL
- E. GSSAPI
Answer: B,C,D
NEW QUESTION # 26
Kafka broker supports which Simple Authentication and Security Layer (SASL) mechanisms for authentication? (Choose three.)
- A. SASL/SAML20
- B. SASL/OTP
- C. SASL/GSSAPI (Kerberos)
- D. SASL/OAUTHBEARER
- E. SASL/PLAIN
Answer: C,D,E
Explanation:
SASL/PLAIN - A simple username/password mechanism supported by Kafka.
SASL/GSSAPI (Kerberos) - Kafka supports Kerberos authentication through the GSSAPI mechanism.
SASL/OAUTHBEARER - Kafka supports OAUTHBEARER for token-based authentication.
NEW QUESTION # 27
In certain scenarios, it is necessary to weigh the trade-off between latency and throughput. One method to increase throughput is to configure batching of messages.
In addition to batch.size, what other producer property can be used to accomplish this?
- A. compression
- B. sendbufferbytes
- C. linger.ms
- D. delivery.timeout.ms
Answer: C
Explanation:
The linger.ms property sets the maximum time the producer will wait before sending a batch, even if the batch isn't full. By increasing linger.ms, you allow more records to accumulate in the batch.
NEW QUESTION # 28
Your organization has a mission-critical Kafka cluster that must be highly available. A Disaster Recovery (DR) cluster has been set up using Replicator, and data is continuously being replicated from source cluster to the DR cluster. However, you notice that the message on offset 1002 on source cluster does not seem to match with offset 1002 on the destination DR cluster.
Which statement is correct?
- A. The DR cluster is lagging behind updates; once the DR cluster catches up, the messages will match.
- B. The offsets for the messages on the source, destination cluster may not match.
- C. The message on DR cluster got over-written accidently by another application.
- D. The message was updated on source cluster, but the update did not flow into destination DR cluster and errored.
Answer: B
Explanation:
When using Confluent Replicator (or MirrorMaker), offsets are not preserved between the source and destination Kafka clusters. Messages are replicated based on content, but they are assigned new offsets in the DR (destination) cluster. Therefore, offset 1002 on the source and offset 1002 on the DR cluster likely refer to different messages, which is expected behavior.
NEW QUESTION # 29
A topic 'recurring payments' is created on a Kafka cluster with three brokers (broker id '0', '1', '2') and nine partitions. The 'min.insync replicas' is set to three, and producer is set with 'acks' as 'all'. Kafka Broker with id '0' is down.
Which statement is correct?
- A. Producers can write messages to all the partitions, because new leaders for the partitions will be elected.
- B. Producers and consumers will have no impact on six of the nine partitions.
- C. Consumers can read committed messages from partitions on broker id T, "2\
- D. Producers will only be able to write messages to the topic where the Leader for the partition is on Broker id T.
Answer: B
Explanation:
With 9 partitions spread across 3 brokers, each broker typically hosts 3 leaders (assuming even distribution). When Broker 0 fails, the partitions for which it was leader will elect new leaders on brokers 1 or 2 if enough in-sync replicas (ISRs) remain. But since min.insync.replicas=3 and only 2 brokers are up, no partition can meet the minimum in-sync replica requirement, so producers with acks=all will fail to write. However, for partitions where Broker 0 is not the leader, consumers can still read committed messages. Given that only 3 partitions likely had Broker 0 as leader, six partitions remain accessible for reads, but not writes.
NEW QUESTION # 30
You have an existing topic t1 that you want to delete because there are no more producers writing to it or consumers reading from it.
What is the recommended way to delete the topic?
- A. Delete the offsets for that topic from the consumer offsets topic.
- B. The consumer should send a message with a 'null' key.
- C. If topic deletion is enabled on the brokers, delete the topic using Kafka command line tools.
- D. Delete the log files and their corresponding index files from the leader broker.
Answer: C
Explanation:
The recommended and safe method to delete a topic is to use the Kafka CLI tool kafka-topics.sh --delete command, provided that delete.topic.enable=true is set on the brokers.
NEW QUESTION # 31
Which use cases would benefit most from continuous event stream processing? (Choose three.)
- A. Historical dashboards
- B. End-of-day financial settlement processing
- C. Context-aware product recommendations for e-commerce
- D. Log monitoring/application fault detection
- E. Fraud detection
Answer: C,D,E
Explanation:
Real-time analysis of transactions helps detect suspicious activity instantly.
Context-aware product recommendations for e-commerce requires real-time user behavior tracking to serve personalized recommendations.
Log monitoring/application fault detection needs immediate processing to alert on system issues or failures.
NEW QUESTION # 32
What is the primary purpose of Kafka quotas?
- A. Guarantee faster response times for some clients.
- B. Throttle clients to prevent them from monopolizing Broker resources.
- C. Limit the number of clients that can connect to the Kafka cluster.
- D. Limit the total number of Partitions in the Kafka cluster
Answer: B
Explanation:
Kafka quotas are used to limit the throughput (bytes/sec) of producers and consumers to ensure fair resource usage and prevent any single client from overwhelming the brokers.
NEW QUESTION # 33
......
Confluent CCAAK Exam Syllabus Topics:
| Topic | Details |
|---|---|
| Topic 1 |
|
| Topic 2 |
|
| Topic 3 |
|
| Topic 4 |
|
| Topic 5 |
|
Real Confluent CCAAK Exam Questions Study Guide: https://guidetorrent.passcollection.com/CCAAK-valid-vce-dumps.html
