
CCAAK Exam Brain Dumps - Study Notes and Theory [Jun-2026]
100% Guaranteed Results CCAAK Unlimited 56 Questions
NEW QUESTION # 12
Which option is a valid Kafka Topic cleanup policy? (Choose two.)
- A. compact
- B. cleanup
- C. delete
- D. default
Answer: A,C
Explanation:
The delete policy deletes old log segments when they exceed the retention period or size.
The compact policy retains only the latest record for each key, enabling efficient key-based storage.
NEW QUESTION # 13
A Kafka administrator notices that their consumers of Topic X are starting to fall behind. The administrator sees that Topic X has four partitions, and the consumer group has two consumers.
Which change can increase the performance of the Consumer Group?
- A. Increase the partitions in Topic X.
- B. Increase the number of consumers in the consumer group.
- C. Create a new consumer group for Topic X containing two (2) consumers.
- D. Decrease the consumer acknowledgment property to increase throughput.
Answer: B
Explanation:
With 4 partitions and only 2 consumers, some consumers are handling multiple partitions, which may cause lag if processing is slow. By increasing the number of consumers in the group (up to 4), Kafka can assign one partition per consumer, improving parallelism and throughput.
NEW QUESTION # 14
Which tool is used for scalably and reliably streaming data between Kafka and other data systems?
- A. Kafka REST Proxy
- B. Kafka Streams
- C. Kafka Schema Registry
- D. Kafka Connect
Answer: D
Explanation:
Kafka Connect is the tool designed for scalable and reliable integration between Kafka and external data systems (e.g., databases, cloud storage, key-value stores). It supports source connectors (to pull data into Kafka) and sink connectors (to push data from Kafka).
NEW QUESTION # 15
Which valid security protocols are included for broker listeners? (Choose three.)
- A. GSSAPI
- B. SASL
- C. SSL
- D. SASL_SSL
- E. PLAINTEXT
Answer: C,D,E
NEW QUESTION # 16
Where are Apache Kafka Access Control Lists stored'?
- A. Schema Registry
- B. Connect
- C. Broker
- D. ZooKeeper
Answer: D
Explanation:
In Apache Kafka (open-source), Access Control Lists (ACLs) are stored in ZooKeeper. Kafka brokers retrieve and enforce ACLs from ZooKeeper at runtime.
NEW QUESTION # 17
Which technology can be used to perform event stream processing? (Choose two.)
- A. Confluent ksqlDB
- B. Confluent Schema Registry
- C. Apache Kafka Streams
- D. Confluent Replicator
Answer: A,C
Explanation:
Kafka Streams is a client library for building real-time applications that process and analyze data stored in Kafka.
ksqlDB enables event stream processing using SQL-like queries, allowing real-time transformation and analysis of Kafka topics.
NEW QUESTION # 18
A company is setting up a log ingestion use case where they will consume logs from numerous systems. The company wants to tune Kafka for the utmost throughput.
In this scenario, what acknowledgment setting makes the most sense?
- A. acks=1
- B. acks=0
- C. acks=all
- D. acks=undefined
Answer: B
Explanation:
acks=0 provides the highest throughput because the producer does not wait for any acknowledgment from the broker. This minimizes latency and maximizes performance.
However, it comes at the cost of no durability guarantees - messages may be lost if the broker fails before writing them. This setting is suitable when throughput is critical and occasional data loss is acceptable, such as in some log ingestion use cases where logs are also stored elsewhere.
NEW QUESTION # 19
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 -> Deny ACL -> Allow ACL -> Deny
- D. Super Users -> Allow ACL -> Deny ACL-> Deny
Answer: D
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 # 20
When a broker goes down, what will the Controller do?
- A. Automatically elect the least loaded broker to become the leader for every orphan's partitions.
- B. Trigger a leader election among the remaining followers to distribute leadership.
- C. Become the leader for the topic/partition that needs a leader, pending the broker return in the cluster.
- D. Wait for a follower to take the lead.
Answer: B
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.
NEW QUESTION # 21
A company is setting up a log ingestion use case where they will consume logs from numerous systems. The company wants to tune Kafka for the utmost throughput.
In this scenario, what acknowledgment setting makes the most sense?
- A. acks=1
- B. acks=0
- C. acks=all
- D. acks=undefined
Answer: B
Explanation:
acks=0 provides the highest throughput because the producer does not wait for any acknowledgment from the broker. This minimizes latency and maximizes performance.
However, it comes at the cost of no durability guarantees - messages may be lost if the broker fails before writing them. This setting is suitable when throughput is critical and occasional data loss is acceptable, such as in some log ingestion use cases where logs are also stored elsewhere.
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 Kafka is also enabled for encryption.
- C. Only if the new Producer disables batching.
- 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
What is the primary purpose of Kafka quotas?
- A. Limit the total number of Partitions in the Kafka cluster
- B. Guarantee faster response times for some clients.
- C. Limit the number of clients that can connect to the Kafka cluster.
- D. Throttle clients to prevent them from monopolizing Broker resources.
Answer: D
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 # 24
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 message was updated on source cluster, but the update did not flow into destination DR cluster and errored.
- B. The message on DR cluster got over-written accidently by another application.
- C. The offsets for the messages on the source, destination cluster may not match.
- D. The DR cluster is lagging behind updates; once the DR cluster catches up, the messages will match.
Answer: C
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 # 25
A company has an existing Kafka cluster running without SSL/TLS enabled. The customer wants to enable SSL on brokers to secure data in transit, but they would like to give applications connecting to this cluster some time to migrate to using SSL connection instead of putting a hard stop.
Which solution will meet the customer's requirements?
- A. Modify the advertised listeners setting on brokers to use SSL.
- B. Create a new listener with SSL enabled.
- C. Enable SSL on the current Listener, and do not enable mTLS.
- D. Enable SSL on the current listener, and do not implement SSL on application side.
Answer: B
Explanation:
Kafka supports multiple listeners, allowing you to run PLAINTEXT and SSL simultaneously. By creating a new SSL-enabled listener (e.g., on a different port), existing applications can continue using PLAINTEXT while gradually migrating to the SSL listener. This approach avoids downtime and gives clients time to adapt without enforcing a hard cutover.
NEW QUESTION # 26
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. sendbufferbytes
- B. delivery.timeout.ms
- C. compression
- D. linger.ms
Answer: D
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 # 27
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 and consumers will have no impact on six of the nine partitions.
- B. Consumers can read committed messages from partitions on broker id T, "2\
- C. Producers will only be able to write messages to the topic where the Leader for the partition is on Broker id T.
- D. Producers can write messages to all the partitions, because new leaders for the partitions will be elected.
Answer: A
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 # 28
What are benefits to gracefully shutting down brokers? (Choose two.)
- A. It will automatically re-elect leaders on restart.
- B. It will sync all its logs to disk to avoid needing to do any log recovery when it restarts.
- C. It will balance the partitions across brokers before restarting.
- D. It will migrate any partitions the server is the leader for to other replicas prior to shutting down.
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 # 29
Which connector type takes data from a topic and sends it to an external data system?
- A. Sink Connector
- B. SvsIog Connector
- C. Streams Connector
- D. Source Connector
Answer: A
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.
NEW QUESTION # 30
How does Kafka guarantee message integrity after a message is written on a disk?
- A. Only message metadata can be altered using command line (CLI) tools.
- B. A message can be edited by the producer, producing to the message offset.
- C. A message cannot be altered once it has been written.
C A message can be grouped with message sharing the same key to improve read performance
Answer: C
Explanation:
Kafka ensures message immutability for data integrity. Once a message is written to a Kafka topic and persisted to disk, it cannot be modified. This immutability guarantees that consumers always receive the original message content, which is critical for auditability, fault tolerance, and data reliability.
NEW QUESTION # 31
Why does Kafka use ZooKeeper? (Choose two.)
- A. For controller election
- B. To scale the number of brokers in the cluster
- C. To prevent replication between clusters
- D. To access information about the leaders and partitions
Answer: A,D
Explanation:
ZooKeeper stores metadata such as partition leadership and ISR (in-sync replicas), which brokers use to coordinate.
Kafka uses ZooKeeper to perform leader election for the Controller broker, which manages cluster metadata and leadership changes.
NEW QUESTION # 32
You want to increase Producer throughput for the messages it sends to your Kafka cluster by tuning the batch size ('batch size') and the time the Producer waits before sending a batch ('linger.ms').
According to best practices, what should you do?
- A. Decrease 'batch.size' and increase 'linger.ms'
- B. Increase 'batch.size' and increase 'linger.ms'
- C. Increase 'batch.size' and decrease 'linger.ms'
- D. Decrease 'batch.size' and decrease 'linger.ms'
Answer: B
Explanation:
Increasing batch.size allows the producer to accumulate more messages into a single batch, improving compression and reducing the number of requests sent to the broker.
Increasing linger.ms gives the producer more time to fill up batches before sending them, which improves batching efficiency and throughput.
This combination is a best practice for maximizing throughput, especially when message volume is high or consistent latency is not a strict requirement.
NEW QUESTION # 33
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?
- A. Four
- B. two
- C. three
- D. One
Answer: D
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.
NEW QUESTION # 34
......
Confluent CCAAK Exam Syllabus Topics:
| Topic | Details |
|---|---|
| Topic 1 |
|
| Topic 2 |
|
| Topic 3 |
|
| Topic 4 |
|
CCAAK Dumps PDF - Want To Pass CCAAK Fast: https://actualtests.prep4away.com/Confluent-certification/braindumps.CCAAK.ete.file.html