CCAAK Exam Questions

In a Kafka cluster, when the broker running the controller thread fails, which broker will become the new controller?

A corporate requirement exists that all data is to be protected on any system where it exists. What steps would you take, as a Kafka Administrator, to protect the data at rest in a...

When a message is committed on a partition, the leader will advance which of the following?

Which model does Kafka use for consumers?

You notice that consumers of Topic X are starting to fall behind. - Topic X has four partitions - The consumer group has two consumers Which change will increase the performance of...

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 topi...

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...

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 be...

You are managing a cluster with a large number of topics, and each topic has a lot of partitions. A team wants to significantly increase the number of partitions for some topics. W...

How can authentication for both internal component traffic and external client traffic be accomplished?

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 --zo...

What is the atomic unit of data in Kafka?

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 applicat...

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 topic...

Which property in broker configuration specifies that a broker belongs to a particular rack?

Which tool is used for scalably and reliably streaming data between Kafka and other data systems?

What is the primary purpose of Kafka quotas?

What does Kafka replication factor provide? (Choose two.)

Which out-of-the-box Kafka Authorizer implementation uses ZooKeeper?

A message written to a Kafka topic results in the creation of a new online shopping order. What is the best method to update the order when a new message is received by Kafka conta...

Several applications are producing messages with different compression formats to a single Kafka topic that has multiple partitions. How will consuming applications become aware of...

On rebalance, calculation of the partition assignment to the Consumer Group members is delegated to which Consumer Group entity?

You need to perform a rolling restart of a Kafka cluster. What are two major considerations to avoid downtime? (Choose two.)

What are two benefits of gracefully shutting down brokers? (Choose two.)

You manage a cluster with a large number of topics, and each topic has many partitions. You need to significantly increase the number of partitions for some topics. What should you...

Which three Simple Authentication and Security Layer (SASL) mechanisms for authentication does a Kafka broker support? (Choose three.)

You are managing a Kafka cluster and notice that a producer is encountering a 'NotEnoughReplicas' exception. What is the reason for the 'NotEnoughReplicas' exception?

Which factor is important for scaling a Kafka cluster to handle increasing data throughput?

Which does the GET /connectors/(string: name)status endpoint return?

You manage Kafka Connect clusters and use the Kafka Connect REST API to monitor the status of various connectors and their tasks. You also restart connectors and update configurati...

You are deploying Kafka Connect in a production environment that requires high availability and the ability to scale with increasing data volume. Which worker type should you choos...

You are responsible for securing a Kafka cluster that handles sensitive financial data. You want to ensure that all data is encrypted while it is being transmitted between clients...

An Apache Kafka® cluster has a topic named T1 with a mix of compressed and uncompressed messages. Which condition allows this?

Which metrics should be set to zero to ensure a healthy Kafka cluster and data consistency?

Which operation requires a broker to restart?

You are setting up a new Kafka cluster using KRaft mode. You need to start up the Kafka cluster in the correct order to avoid startup issues. Which sequence should you use to start...

Which type of model does Kafka use for consumers to retrieve messages?

When attempting to read from a subscribed topic, a consumer application is not seeing produced messages. Which of the following could be the cause? (Choose two.)

Kafka Streams applications can add extra load to the Kafka cluster even though stream processing doesn't take place on the Kafka cluster itself. Which of the following increase the...

Which of the following is not true about the In-Sync Replica list?

A group of five consumers is consuming a topic with 10 partitions. You notice that the consumer group is not catching up with the rate of messages produced in the topic. You need t...

You need to design a Kafka cluster that can tolerate the failure of up to two brokers without data loss. Which two factors should you consider when configuring your Kafka cluster?...

You manage a Kafka cluster and notice that a specific topic continues to receive messages after the known producer has stopped. You suspect there is an unknown producer still sendi...

You are deploying an Apache Kafka® cluster to ensure high availability and fault tolerance. Which deployment pattern should you choose to achieve this?

You use Kafka deployed on-premises to keep track of inventory and item availability. Since Kafka is running on-premises and is in a private network, data is transmitted in plain te...

Your company's best practices dictate that there is no single point of failure for all data stored. What should you do to comply with this best practice when creating Kafka topics?

You need to configure 'process.roles' in a Kafka cluster running in KRaft mode. Which two configurations will ensure proper metadata management and broker operations? (Choose two.)

You run a large Kafka cluster on a well-known public cloud that uses the cloud provider's native filesystem encryption to encrypt data at rest. The brokers in this cluster authenti...

What are two valid Kafka topic cleanup policies? (Choose two.)

How does Kafka achieve high availability?