Spring Sale Special Limited Time 70% Discount Offer - Ends in 0d 00h 00m 00s - Coupon code: buysanta

Exact2Pass Menu

Confluent Certified Administrator for Apache Kafka

Last Update 2 hours ago Total Questions : 54

The Confluent Certified Administrator for Apache Kafka content is now fully updated, with all current exam questions added 2 hours ago. Deciding to include CCAAK practice exam questions in your study plan goes far beyond basic test preparation.

You'll find that our CCAAK exam questions frequently feature detailed scenarios and practical problem-solving exercises that directly mirror industry challenges. Engaging with these CCAAK sample sets allows you to effectively manage your time and pace yourself, giving you the ability to finish any Confluent Certified Administrator for Apache Kafka practice test comfortably within the allotted time.

Question # 1

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

A.

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

B.

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

C.

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

D.

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

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"

}

A.

Increase the number of Connect Nodes.

B.

Increase the number of Connect Tasks (tasks max value).

C.

Increase the number of partitions.

D.

Increase the replication factor and increase the number of Connect Tasks.

Question # 3

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.

Which parameters should you check before increasing the partitions?

A.

Check the producer batch size and buffer size.

B.

Check if compression is being used.

C.

Check the max open file count on brokers.

D.

Check if acks=all is being used.

Question # 4

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, what acknowledgment setting makes the most sense?

A.

acks=0

B.

acks=1

C.

acks=all

D.

acks=undefined

Question # 5

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.

sendbufferbytes

B.

linger.ms

C.

compression

D.

delivery.timeout.ms

Question # 6

Multiple clients are sharing a Kafka cluster.

As an administrator, how would you ensure that Kafka resources are distributed fairly to all clients?

A.

Quotas

B.

Consumer Groups

C.

Rebalancing

D.

ACLs

Question # 7

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

A.

Configure multiple brokers.

B.

Configure multiple listeners on the broker.

C.

Configure multiple security protocols on the same listener.

D.

Configure LoadBalancer.

Question # 8

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

A.

connect-confiqs

B.

connect-distributed

C.

connect-status

D.

connect-standalone

E.

connect-offsets

Question # 9

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.

processing.guarantee=exactly_once

B.

ksql.streams auto offset.reset=earliest

C.

ksql.streams auto.offset.reset=latest

D.

ksql.fail.on.production.error=false

Question # 10

You have a Kafka cluster with topics t1 and t2. In the output below, topic t2 shows Partition 1 with a leader “-1”.

...

$ kafka-topics --zookeeper localhost:2181 --describe --topic t2

Topic: t2 Partition: 1 Leader: -1 Replicas: 1 Isr:

What is the most likely reason for this?

A.

Broker 1 failed.

B.

Leader shows “-1” while the log cleaner thread runs on Broker 1.

C.

Compression has been enabled on Broker 1.

D.

Broker 1 has another partition clashing with the same name.

Go to page: