Confluent CCAAK Certified Administrator for Apache Kafka Exam Practice Test

Page: 1 / 14
Total 54 questions
Question 1

A broker in the Kafka cluster is currently acting as the Controller.

Which statement is correct?



Answer : A

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.


Question 2

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"

}



Answer : B

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 3

Kafka broker supports which Simple Authentication and Security Layer (SASL) mechanisms for authentication? (Choose three.)



Answer : A, C, D

SASL/PLAIN -- A simple username/password mechanism supported by Kafka.

SASL/GSSAPI (Kerberos) -- Kafka supports Kerberos authentication through the GSSAPI mechanism.

SASL/OAUTHBEARER -- Kafka supports OAUTHBEARER for token-based authentication.


Question 4

An employee in the reporting department needs assistance because their data feed is slowing down. You start by quickly checking the consumer lag for the clients on the data stream.

Which command will allow you to quickly check for lag on the consumers?



Answer : B

The kafka-consumer-groups.sh script is used to inspect consumer group details, including consumer lag, which indicates how far behind a consumer is from the latest data in the partition.

The typical usage is bin/kafka-consumer-groups.sh --bootstrap-server --describe --group <group_id>


Question 5

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



Answer : A, B, C

The complexity of the schema (number of fields, data types, etc.) affects processing and memory usage.

Each ksqlDB persistent query consumes resources (CPU, memory), so more queries require more capacity.

More partitions increase parallelism, but also resource usage, especially in scaling and state management.


Question 6

Which valid security protocols are included for broker listeners? (Choose three.)



Answer : A, B, D


Question 7

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 'auto.offset.reset' does NOT apply?



Answer : D

In this scenario, the offset itself is still valid, even though the record at that offset was compacted away. The consumer can continue consuming from the next available record. Therefore, auto.offset.reset does NOT apply, because there is a valid offset present.


Page:    1 / 14   
Total 54 questions