A Review Of Download CCDAK Exam Price

NEW QUESTION 1
A consumer is configured with enable.auto.commit=false. What happens when close() is called on the consumer object?

• A. The uncommitted offsets are committed
• B. A rebalance in the consumer group will happen immediately
• C. The group coordinator will discover that the consumer stopped sending heartbeat
• D. It will cause rebalance after session.timeout.ms

Answer: B

Explanation:
Calling close() on consumer immediately triggers a partition rebalance as the consumer will not be available anymore.

NEW QUESTION 2
You are building a consumer application that processes events from a Kafka topic. What is the most important metric to monitor to ensure real-time processing?

• A. UnderReplicatedPartitions
• B. records-lag-max
• C. MessagesInPerSec
• D. BytesInPerSec

Answer: B

Explanation:
This metric shows the current lag (number of messages behind the broker)

NEW QUESTION 3
You are sending messages with keys to a topic. To increase throughput, you decide to
increase the number of partitions of the topic. Select all that apply.

• A. All the existing records will get rebalanced among the partitions to balance load
• B. New records with the same key will get written to the partition where old records with that key were written
• C. New records may get written to a different partition
• D. Old records will stay in their partitions

Answer: CD

Explanation:
Increasing the number of partition causes new messages keys to get hashed differently, and breaks the guarantee "same keys goes to the same partition". Kafka logs are immutable and the previous messages are not re-shuffled

NEW QUESTION 4
There are 3 producers writing to a topic with 5 partitions. There are 10 consumers consuming from the topic as part of the same group. How many consumers will remain idle?

• A. 10
• B. 3
• C. None
• D. 5

Answer: D

Explanation:
One consumer per partition assignment will keep 5 consumers idle.

NEW QUESTION 5
What Java library is KSQL based on?

• A. Kafka Streams
• B. REST Proxy
• C. Schema Registry
• D. Kafka Connect

Answer: A

Explanation:
KSQL is based on Kafka Streams and allows you to express transformations in the SQL language that get automatically converted to a Kafka Streams program in the backend

NEW QUESTION 6
In Java, Avro SpecificRecords classes are

• A. automatically generated from an Avro Schema
• B. written manually by the programmer
• C. automatically generated from an Avro Schema + a Maven / Gradle Plugin

Answer: C

Explanation:
SpecificRecord is created from generated record classes

NEW QUESTION 7
When is the onCompletion() method called?
private class ProducerCallback implements Callback {
@Override
public void onCompletion(RecordMetadata recordMetadata, Exception e) { if (e != null) {

• A. e.printStackTrace();}}}ProducerRecord<String, String> record =new ProducerRecord<>("topic1", "key1", "value1"); producer.send(record, new ProducerCallback());
• B. When the message is partitioned and batched successfully
• C. When message is serialized successfully
• D. When the broker response is received
• E. When send() method is called

Answer: C

Explanation:
Callback is invoked when a broker response is received.

NEW QUESTION 8
If you enable an SSL endpoint in Kafka, what feature of Kafka will be lost?

• A. Cross-cluster mirroring
• B. Support for Avro format
• C. Zero copy
• D. Exactly-once delivery

Answer: C

Explanation:
With SSL, messages will need to be encrypted and decrypted, by being first loaded into the JVM, so you lose the zero copy optimization. See more information herehttps://twitter.com/ijuma/status/1161303431501324293?s=09

NEW QUESTION 9
You want to sink data from a Kafka topic to S3 using Kafka Connect. There are 10 brokers in the cluster, the topic has 2 partitions with replication factor of 3. How many tasks will you configure for the S3 connector?

• A. 10
• B. 6
• C. 3
• D. 2

Answer: D

Explanation:
You cannot have more sink tasks (= consumers) than the number of partitions, so 2.

NEW QUESTION 10
Which of the following is true regarding thread safety in the Java Kafka Clients?

• A. One Producer can be safely used in multiple threads
• B. One Consumer can be safely used in multiple threads
• C. One Consumer needs to run in one thread
• D. One Producer needs to be run in one thread

Answer: AC

Explanation:
KafkaConsumer is not thread-safe, KafkaProducer is thread safe.

NEW QUESTION 11
To allow consumers in a group to resume at the previously committed offset, I need to set the proper value for...

• A. value.deserializer
• B. auto.offset.resets
• C. group.id
• D. enable.auto.commit

Answer: C

Explanation:
Setting a group.id that's consistent across restarts will allow your consumers part of the same group to resume reading from where offsets were last committed for that group

NEW QUESTION 12
Your producer is producing at a very high rate and the batches are completely full each
time. How can you improve the producer throughput? (select two)

• A. Enable compression
• B. Disable compression
• C. Increase batch.size
• D. Decrease batch.size
• E. Decrease linger.ms Increase linger.ms

Answer: AC

Explanation:
batch.size controls how many bytes of data to collect before sending messages to the Kafka broker. Set this as high as possible, without exceeding available memory. Enabling compression can also help make more compact batches and increase the throughput of your producer. Linger.ms will have no effect as the batches are already full

NEW QUESTION 13
while (true) {
ConsumerRecords<String, String> records = consumer.poll(100); try {
consumer.commitSync();
} catch (CommitFailedException e) { log.error("commit failed", e)
}
for (ConsumerRecord<String, String> record records)
{
System.out.printf("topic = %s, partition = %s, offset =
%d, customer = %s, country = %s ",
record.topic(), record.partition(), record.offset(), record.key(), record.value());
}
}
What kind of delivery guarantee this consumer offers?

• A. Exactly-once
• B. At-least-once
• C. At-most-once

Answer: C

Explanation:
Here offset is committed before processing the message. If consumer crashes before processing the message, message will be lost when it comes back up.

NEW QUESTION 14
You are using JDBC source connector to copy data from 2 tables to two Kafka topics. There is one connector created with max.tasks equal to 2 deployed on a cluster of 3 workers. How many tasks are launched?

• A. 6
• B. 1
• C. 2
• D. 3

Answer: C

Explanation:
we have two tables, so the max number of tasks is 2

NEW QUESTION 15
If I want to have an extremely high confidence that leaders and replicas have my data, I
should use

• A. acks=all, replication factor=2, min.insync.replicas=1
• B. acks=1, replication factor=3, min.insync.replicas=2
• C. acks=all, replication factor=3, min.insync.replicas=2
• D. acks=all, replication factor=3, min.insync.replicas=1

Answer: C

Explanation:
acks=all means the leader will wait for all in-sync replicas to acknowledge the record. Also the min in-sync replica setting specifies the minimum number of replicas that need to be in- sync for the partition to remain available for writes.

NEW QUESTION 16
Where are the ACLs stored in a Kafka cluster by default?

• A. Inside the broker's data directory
• B. Under Zookeeper node /kafka-acl/
• C. In Kafka topic kafka_acls
• D. Inside the Zookeeper's data directory

Answer: A

Explanation:
ACLs are stored in Zookeeper node /kafka-acls/ by default.

NEW QUESTION 17
......