CCAAK Exam Questions

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

When is the resource authorization checked while using Kafka ACLs?

An employee in the reporting department needs assistance because their data feed is slowing down. You need to check the consumer lag for the clients on the data stream. Which comma...

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

How does Kafka guarantee message integrity after a message is written on a disk?

Which option is a valid Kafka Topic cleanup policy? (Choose two.)

What is the correct permission check sequence for Kafka ACLs?

The Consumer property 'auto offset reset' determines what to do if there is no valid offset for a Consumer Group. Which scenario is an example of a valid offset and therefore the '...

Which ksqlDB statement produces data that is persisted into a Kafka topic?

A broker in the Kafka cluster is currently acting as the Controller. Which statement is correct?

Why does Kafka use ZooKeeper? (Choose two.)

What are important factors in sizing a ksqlDB cluster? (Choose three.)

Where are Apache Kafka Access Control Lists stored'?

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

What is the primary feature in Kafka that allows for scalability and parallelism by dividing incoming data into smaller manageable units, enabling high throughput and allowing data...

You use Kafka to process financial transactions in real time. All clients that interact with Kafka must set a descriptive 'clientID', use 'acks=all', and enable compression. A revi...

Your cluster is experiencing increased produce and consume traffic. To ensure the Kafka cluster can handle the load, you add more brokers to the cluster. You need to ensure the new...

You want to increase producer throughput for messages sent to your Kafka cluster by tuning the properties 'batch.size' and 'linger.ms'. According to best practices, what should you...

What is the relationship between a broker and a topic?

You work for a ride hailing company using Kafka to get real-time location updates from customers and drivers. You need to collect Kafka metrics to better understand the health and...

Your Kafka team needs to implement authentication and authorization via SSL/TLS for all clients. Even communication between the Kafka brokers should be encrypted. You must determin...

While managing a Kafka cluster, you notice that a producer fails to send messages to a Kafka topic. The logs show an error: 'org.apache.kafka.common.errors.RecordTooLargeException'...

Which action does the Kafka Controller take regarding leadership of the broker's partitions when a Kafka broker fails?

You need to identify corrupt records in the partition log segments messages that your consumer cannot handle. Which tool can you use to decode Kafka log segments to review individu...

You are performing an in-place upgrade of an Apache Kafka® cluster and the inter.broker.protocol.version (IBP) must be updated. You need to complete the update and ensure a smooth...

You are setting up a Kafka cluster using KRaft mode and need to ensure that only specific users have permissions to create and manage topics. Which three actions are necessary when...

You have a mission-critical Kafka cluster that must be highly available. A Disaster Recovery (DR) cluster is using MirrorMaker and data is continuously replicated from the source c...

Your company uses a Kafka cluster with end-to-end encryption to process payments and financial transactions in real time. The Kafka cluster is slowing as you onboard new customers...

You are running a producer application that is writing messages to a Kafka topic named order_updated. Topic is created with 10 partitions and replication factor of 3. After monitor...

You are designing a Kafka-based application to process real-time data. Your application needs to separate incoming sensor data into categories such as 'Temperature Readings', 'Pres...

For a Kafka cluster running in KRaft mode, how is a new controller leader elected after an existing controller leader dies?

You need to create ACLs for an application that will produce to any topic that uses a prefix 'updated-working-hours-for-store-id-'. You have the following security requirements: -...

Kafka Connect is running on a two-node cluster in distributed mode. The connector: - Is a source connector pulling data from relational database tables (users/payment/orders) - Wri...

You are integrating Kafka with a relational database to capture changes in real time. Which component should you use for this task?

You notice increased latency and occasional connectivity issues between Kafka brokers and clients. You suspect the network configuration might be the cause. You need to resolve the...

You are responsible for the operation and performance tuning of a Kafka cluster. This Kafka cluster handles a variety of workloads including real-time transaction processing, large...

You manage a Kafka cluster in KRaft mode deployed across multiple data centers. You observed intermittent issues where brokers are frequently leaving the cluster and reconnecting....

You manage a Kafka Connect cluster with several source and sink connectors. A source connector that reads data from an external system encounters an issue and needs to reset is off...

By default, what do Kafka broker network connections have?

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

You are using Confluent Schema Registry to provide a RESTful interface for storing and retrieving schemas. Which types of schemas are supported? (Choose three.)

Multiple clients are sharing a Kafka cluster. As an administrator, how would you ensure that Kafka resources are distributed fairly to all clients?

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

If a broker's JVM garbage collection takes too long, what can occur?

You are managing a Kafka cluster with five brokers (broker id '0', '1','2','3','4') and three ZooKeepers. There are 100 topics, five partitions for each topic, and replication fact...

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

Which technology can be used to perform event stream processing? (Choose two.)

How can load balancing of Kafka clients across multiple brokers be accomplished?

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

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