[Feb-2026] Check your preparation for Confluent CCAAK On-Demand Exam
Practice Exam CCAAK Realistic Dumps Verified Questions
NEW QUESTION # 17
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. If topic deletion is enabled on the brokers, delete the topic using Kafka command line tools.
- B. Delete the log files and their corresponding index files from the leader broker.
- C. The consumer should send a message with a 'null' key.
- D. Delete the offsets for that topic from the consumer offsets topic.
Answer: A
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 # 18
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. linger.ms
- B. sendbufferbytes
- C. delivery.timeout.ms
- D. compression
Answer: A
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 # 19
Which option is a valid Kafka Topic cleanup policy? (Choose two.)
- A. cleanup
- B. compact
- C. delete
- D. default
Answer: B,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 # 20
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. Create a new consumer group for Topic X containing two (2) consumers.
- B. Decrease the consumer acknowledgment property to increase throughput.
- C. Increase the partitions in Topic X.
- D. Increase the number of consumers in the consumer group.
Answer: D
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 # 21
Which model does Kafka use for consumers?
- A. Enrollment
- B. Push
- C. Publish
- D. Pull
Answer: D
Explanation:
Kafka uses a pull model for consumers, where consumers poll the broker to retrieve messages at their own pace. This model gives consumers more control over flow and backpressure, improving scalability and reliability.
NEW QUESTION # 22
What is the correct permission check sequence for Kafka ACLs?
What is the correct permission check sequence for Kafka ACLs?
- A. Super Users -> Deny ACL -> Allow ACL -> Deny
- B. Allow ACL -> Deny ACL -> Super Users -> Deny
- C. Deny ACL -> Deny -> Allow ACL -> Super Users
- 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 # 23
Which property in broker configuration specifies that a broker belongs to a particular rack?
Which property in broker configuration specifies that a broker belongs to a particular rack?
- A. broker.rack
- B. client.rack
- C. kafka.rack
- D. zookeeper.rack
Answer: A
Explanation:
The broker.rack property is used in a Kafka broker's configuration to specify the rack or availability zone the broker belongs to. This is important for rack-aware replica placement, allowing Kafka to distribute replicas across different racks for fault tolerance.
NEW QUESTION # 24
By default, what do Kafka broker network connections have?
- A. Encryption, but no authentication or authorization
- B. No encryption, no authentication and no authorization
- C. Encryption and authentication, but no authorization
- D. No encryption, no authorization, but have authentication
Answer: B
Explanation:
By default, Kafka brokers use the PLAINTEXT protocol for network communication. This means:
* No encryption - data is sent in plain text.
* No authentication - any client can connect without verifying identity.
* No authorization - there are no access control checks by default.
Security features like TLS, SASL, and ACLs must be explicitly configured.
NEW QUESTION # 25
Which connector type takes data from a topic and sends it to an external data system?
- A. SvsIog Connector
- B. Sink Connector
- C. Source Connector
- D. Streams Connector
Answer: B
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 # 26
Which tool is used for scalably and reliably streaming data between Kafka and other data systems?
- A. Kafka Schema Registry
- B. Kafka Streams
- C. Kafka REST Proxy
- 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 # 27
A broker in the Kafka cluster is currently acting as the Controller.
Which statement is correct?
- A. It is responsible for sending leader information to all producers.
- B. It can have topic partitions.
- C. It is given precedence for replication to and from replica followers.
- D. All consumers are allowed to fetch messages only from this server.
Answer: B
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 # 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 message on DR cluster got over-written accidently by another application.
- C. The message was updated on source cluster, but the update did not flow into destination DR cluster and errored.
- D. The offsets for the messages on the source, destination cluster may not match.
Answer: D
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 customer has a use case for a ksqlDB persistent query. You need to make sure that duplicate messages are not processed and messages are not skipped.
Which property should you use?
- A. ksql.streams auto.offset.reset=latest
- B. processing.guarantee=exactly_once
- C. ksql.fail.on.production.error=false
- D. ksql.streams auto offset.reset=earliest
Answer: B
Explanation:
processing.guarantee=exactly_once ensures that messages are processed exactly once by ksqlDB, preventing both duplicates and message loss.
NEW QUESTION # 30
Where are Apache Kafka Access Control Lists stored'?
- A. Schema Registry
- B. ZooKeeper
- C. Connect
- D. Broker
Answer: B
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 # 31
What does Kafka replication factor provide? (Choose two.)
- A. Availability
- B. Performance
- C. Durability
- D. Security
Answer: A,C
Explanation:
Replication ensures that multiple copies of data exist across different brokers, so data is not lost if one broker fails.
With multiple replicas, Kafka can continue to serve data even if the leader or one replica fails, maintaining service availability.
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 decrease 'linger.ms'
- B. Increase 'batch.size' and decrease 'linger.ms'
- C. Increase 'batch.size' and increase 'linger.ms'
- D. Decrease 'batch.size' and increase 'linger.ms'
Answer: C
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
How can authentication for both internal component traffic and external client traffic be accomplished?
- A. Configure LoadBalancer.
- B. Configure multiple security protocols on the same listener.
- C. Configure multiple brokers.
- D. Configure multiple listeners on the broker.
Answer: D
Explanation:
Kafka supports multiple listeners, each with its own port, hostname, and security protocol. This allows you to:
* Use one listener for internal communication (e.g., brokers, ZooKeeper, Connect, etc.) with one type of authentication (e.g., PLAINTEXT or SASL).
* Use a separate listener for external clients (e.g., producers and consumers) with a different protocol (e.g., SSL or SASL_SSL).
NEW QUESTION # 34
Which ksqlDB statement produces data that is persisted into a Kafka topic?
- A. CREATE TABLE
- B. SELECT (Pull Query)
- C. SELECT (Push Query)
- 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 # 35
A developer is working for a company with internal best practices that dictate that there is no single point of failure for all data stored.
What is the best approach to make sure the developer is complying with this best practice when creating Kafka topics?
- A. Set 'min.insync.replicas' to 1.
- B. Set the topic replication factor to 3.
- C. Use the parameter --partitions=3 when creating the topic.
- D. Make sure the topics are created with linger.ms=0 so data is written immediately and not held in batch.
Answer: B
Explanation:
Replication factor determines how many copies of each partition exist across different brokers. A replication factor of 3 ensures that even if one or two brokers fail, the data is still available, thus eliminating a single point of failure.
NEW QUESTION # 36
What is the primary purpose of Kafka quotas?
- A. Limit the number of clients that can connect to the Kafka cluster.
- B. Limit the total number of Partitions in the Kafka cluster
- C. Throttle clients to prevent them from monopolizing Broker resources.
- D. Guarantee faster response times for some clients.
Answer: C
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 # 37
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. Leader shows "-1" while the log cleaner thread runs on Broker 1.
- B. Broker 1 has another partition clashing with the same name.
- C. Compression has been enabled on Broker 1.
- D. Broker 1 failed.
Answer: D
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 # 38
What are benefits to gracefully shutting down brokers? (Choose two.)
- A. It will sync all its logs to disk to avoid needing to do any log recovery when it restarts.
- 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 balance the partitions across brokers before restarting.
Answer: A,B
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 # 39
......
Valid CCAAK Dumps for Helping Passing Confluent Exam: https://www.surepassexams.com/CCAAK-exam-bootcamp.html
Download Free Confluent CCAAK Exam Questions & Answer: https://drive.google.com/open?id=1j0QrftNMjmrVJWBFRs4pOY0cWaRifvro