Limited-Time Offer: Enjoy 50% Savings! Ends in 00h 00m 00s Coupon code: 50OFF
Skip to content

Free Confluent Certified Administrator for Apache Kafka CCAAK Exam Questions

Page: 1 / 6 Total 54 questions

Want more questions? Get Premium Access.

Question 1

A Kafka cluster with three brokers has a topic with 10 partitions and a replication factor set to three. Each partition stores 25 GB data per day and data retention is set to 24 hours.

How much storage will be consumed by the topic on each broker?

Correct Answer: C. 300 GB
Explanation:

10 partitions 25 GB/day = 250 GB total per day for the topic (primary data).

With a replication factor of 3, there are 3 full copies of the data: 250 GB 3 = 750 GB total across the entire cluster.

The cluster has 3 brokers, and Kafka tries to distribute replicas evenly among them: 750 GB 3 brokers = 250 GB per broker on average.

However, due to replication, some partitions have leaders and followers, so there's some overlap and not-perfect distribution. Each broker stores approximately 2/3 of the total topic data (since each broker holds replicas for around 2/3 of the partitions).

2/3 750 GB = 500 GB, but this is shared, so each broker ends up storing ~300 GB of replicated data, including its share of leaders and followers.


Question 2

When a broker goes down, what will the Controller do?

Correct Answer: B. Trigger a leader election among the remaining followers to distribute leadership.
Explanation:

When a broker goes down, the Controller detects the failure and triggers a leader election for all partitions that had their leader on the failed broker. The leader is chosen from the in-sync replicas (ISRs) of each partition.


Question 3

Which connector type takes data from a topic and sends it to an external data system?

Correct Answer: A. Sink Connector
Explanation:

A Sink Connector reads data from a Kafka topic and writes it to an external data system, such as a database, file system, or cloud service.


Question 4

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?

Correct Answer: C. The offsets for the messages on the source, destination cluster may not match.
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.


Question 5

Kafka Connect is running on a two node cluster in distributed mode. The connector is a source connector that pulls data from Postgres tables (users/payment/orders), writes to topics with two partitions, and with replication factor two. The development team notices that the data is lagging behind.

What should be done to reduce the data lag*?

The Connector definition is listed below:

{

"name": "confluent-postgresql-source",

"connector class": "PostgresSource",

"topic.prefix": "postgresql_",

& nbsp;& nbsp;& nbsp;...

"db.name": "postgres",

"table.whitelist": "users.payment.orders'',

"timestamp.column.name": "created_at",

"output.data format": "JSON",

"db.timezone": "UTC",

"tasks.max": "1"

}

Correct Answer: B. Increase the number of Connect Tasks (tasks max value).
Explanation:

The connector is currently configured with 'tasks.max': '1', which means only one task is handling all tables (users, payment, orders). This can create a bottleneck and lead to lag. Increasing tasks.max allows Kafka Connect to parallelize work across multiple tasks, which can pull data from different tables concurrently and reduce lag.


Question 6

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:

Correct Answer: A. Broker 1 failed.
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.


Question 7

Your Kafka cluster has four brokers. The topic t1 on the cluster has two partitions, and it has a replication factor of three. You create a Consumer Group with four consumers, which subscribes to t1.

In the scenario above, how many Controllers are in the Kafka cluster?

Correct Answer: A. One
Explanation:

In a Kafka cluster, only one broker acts as the Controller at any given time. The Controller is responsible for managing cluster metadata, such as partition leadership and broker status. Even if the cluster has multiple brokers (in this case, four), only one is elected as the Controller, and others serve as regular brokers. If the current Controller fails, another broker is automatically elected to take its place.


Question 8

What is the correct permission check sequence for Kafka ACLs?

What is the correct permission check sequence for Kafka ACLs?

Correct Answer: D. Super Users -> Allow ACL -> Deny ACL-> Deny
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.


Question 9

What is the relationship between topics and partitions? (Choose two.)

Correct Answer: B. Atopic may have more than one partition.; C. A partition is always linked to a single topic.
Explanation:

Kafka topics are split into one or more partitions to enable parallelism and scalability.

Each partition belongs to exactly one topic; it cannot span multiple topics.


Question 10

Which of the following are Kafka Connect internal topics? (Choose three.)

Correct Answer: A. connect-confiqs; C. connect-status; E. connect-offsets
Explanation:

connect-configs stores connector configurations.

connect-status tracks the status of connectors and tasks (e.g., RUNNING, FAILED).

connect-offsets stores source connector offsets for reading from external systems.