Confluent CCAAK Exam Practice Test Instant Access

Question 1

Which connector type takes data from a topic and sends it to an external data system?

ASink Connector

BSource Connector

CStreams Connector

DSvsIog Connector

Answer : A

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.

Question 2

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?

AIf the new Producer is configured to use compression.

BNever, because topic t1 already has uncompressed messages.

COnly if Kafka is also enabled for encryption.

DOnly if the new Producer disables batching.

Answer : A

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

Question 3

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?

Aprocessing.guarantee=exactly_once

Bksql.streams auto offset.reset=earliest

Cksql.streams auto.offset.reset=latest

Dksql.fail.on.production.error=false

Answer : A

processing.guarantee=exactly_once ensures that messages are processed exactly once by ksqlDB, preventing both duplicates and message loss.

Question 4

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

Aclient.rack

Bbroker.rack

Czookeeper.rack

Dkafka.rack

Answer : B

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.

Question 5

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

AData Schema

BNumber of Queries

CNumber of Partitions

DData Encryption

ETopic Data Retention

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

If the Controller detects the failure of a broker that was the leader for some partitions, which actions will be taken? (Choose two.)

AThe Controller waits for a new leader to be nominated by ZooKeeper.

BThe Controller persists the new leader and ISR list to ZooKeeper.

CThe Controller sends the new leader and ISR list changes to all brokers.

DThe Controller sends the new leader and ISR list changes to all producers and consumers.

Answer : B, C

The Controller updates ZooKeeper with the new leader and in-sync replica (ISR) information to maintain metadata consistency.

Brokers need this information to correctly route client requests and continue replication.

Question 7

You are using Confluent Schema Registry to provide a RESTful interface for storing and retrieving schemas.

Which types of schemas are supported? (Choose three.)

AAvro

BgRPC

CJSON

DThrift

EProtobuf

Answer : A, C, E

Avro is the original and most commonly used schema format supported by Schema Registry.

Confluent Schema Registry supports JSON Schema for validation and compatibility checks.

Protocol Buffers (Protobuf) are supported for schema management in Schema Registry.

Confluent Certified Administrator for Apache Kafka CCAAK Exam Practice Test