Latest Confluent Certified Developer For Apache Kafka Certification Examination CCDAK Exam Dumps

NEW QUESTION 1
A consumer wants to read messages from a specific partition of a topic. How can this be achieved?

• A. Call subscribe(String topic, int partition) passing the topic and partition number as the arguments
• B. Call assign() passing a Collection of TopicPartitions as the argument
• C. Call subscribe() passing TopicPartition as the argument

Answer: B

Explanation:
assign() can be used for manual assignment of a partition to a consumer, in which case subscribe() must not be used. Assign() takes a collection of TopicPartition object as an argument https://kafka.apache.org/23/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.ht
ml#assign-java.util.Collection-

NEW QUESTION 2
A producer application in a developer machine was able to send messages to a Kafka topic. After copying the producer application into another developer's machine, the producer is able to connect to Kafka but unable to produce to the same Kafka topic because of an authorization issue. What is the likely issue?

• A. Broker configuration needs to be changed to allow a different producer
• B. You cannot copy a producer application from one machine to another
• C. The Kafka ACL does not allow another machine IP
• D. The Kafka Broker needs to be rebooted

Answer: C

Explanation:
ACLs take "Host" as a parameter, which represents an IP. It can be * (all IP), or a specific IP. Here, it's a specific IP as moving a producer to a different machine breaks the consumer, so the ACL needs to be updated

NEW QUESTION 3
You want to send a message of size 3 MB to a topic with default message size configuration. How does KafkaProducer handle large messages?

• A. KafkaProducer divides messages into sizes of max.request.size and sends them in order
• B. KafkaProducer divides messages into sizes of message.max.bytes and sends them in order
• C. MessageSizeTooLarge exception will be thrown, KafkaProducer will not retry and return exception immediately
• D. MessageSizeTooLarge exception will be thrown, KafkaProducer retries until the number of retries are exhausted

Answer: C

Explanation:
MessageSizeTooLarge is not a retryable exception.

NEW QUESTION 4
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 5
A Zookeeper configuration has tickTime of 2000, initLimit of 20 and syncLimit of 5. What's the timeout value for followers to connect to Zookeeper?

• A. 20 sec
• B. 10 sec
• C. 2000 ms
• D. 40 sec

Answer: D

Explanation:
tick time is 2000 ms, and initLimit is the config taken into account when establishing a connection to Zookeeper, so the answer is 2000 * 20 = 40000 ms = 40s

NEW QUESTION 6
Which of the following Kafka Streams operators are stateful? (select all that apply)

• A. flatmap
• B. reduce
• C. joining
• D. count
• E. peek
• F. aggregate

Answer: BCDF

Explanation:
Seehttps://kafka.apache.org/20/documentation/streams/developer-guide/dsl- api.html#stateful-transformations

NEW QUESTION 7
To transform data from a Kafka topic to another one, I should use

• A. Kafka Connect Sink
• B. Kafka Connect Source
• C. Consumer + Producer
• D. Kafka Streams

Answer: D

Explanation:
Kafka Streams is a library for building streaming applications, specifically applications that transform input Kafka topics into output Kafka topics

NEW QUESTION 8
Consumer failed to process record # 10 and succeeded in processing record # 11. Select the course of action that you should choose to guarantee at least once processing

• A. Commit offsets at 10
• B. Do not commit until successfully processing the record #10
• C. Commit offsets at 11

Answer: C

Explanation:
Here, you shouldn't commit offsets 11 or 10 as it would indicate that the message #10 has been processed successfully.

NEW QUESTION 9
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 10
In Kafka Streams, by what value are internal topics prefixed by?

• A. tasks-<number>
• B. application.id
• C. group.id
• D. kafka-streams-

Answer: B

Explanation:
In Kafka Streams, the application.id is also the underlying group.id for your consumers, and the prefix for all internal topics (repartition and state)

NEW QUESTION 11
Which of the following statements are true regarding the number of partitions of a topic?

• A. The number of partitions in a topic cannot be altered
• B. We can add partitions in a topic by adding a broker to the cluster
• C. We can add partitions in a topic using the kafka-topics.sh command
• D. We can remove partitions in a topic by removing a broker
• E. We can remove partitions in a topic using the kafka-topics.sh command

Answer: C

Explanation:
We can only add partitions to an existing topic, and it must be done using the kafka- topics.sh command

NEW QUESTION 12
Where are KSQL-related data and metadata stored?

• A. Kafka Topics
• B. Zookeeper
• C. PostgreSQL database
• D. Schema Registry

Answer: A

Explanation:
metadata is stored in and built from the KSQL command topic. Each KSQL server has its own in-memory version of the metastore.

NEW QUESTION 13
A consumer starts and has auto.offset.reset=latest, and the topic partition currently has data for offsets going from 45 to 2311. The consumer group has committed the offset 643 for the topic before. Where will the consumer read from?

• A. it will crash
• B. offset 2311
• C. offset 643
• D. offset 45

Answer: C

Explanation:
The offsets are already committed for this consumer group and topic partition, so the property auto.offset.reset is ignored

NEW QUESTION 14
A producer is sending messages with null key to a topic with 6 partitions using the DefaultPartitioner. Where will the messages be stored?

• A. Partition 5
• B. Any of the topic partitions
• C. The partition for the null key
• D. Partition 0

Answer: A

Explanation:
Message with no keys will be stored with round-robin strategy among partitions.

NEW QUESTION 15
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 16
You are doing complex calculations using a machine learning framework on records fetched from a Kafka topic. It takes more about 6 minutes to process a record batch, and the consumer enters rebalances even though it's still running. How can you improve this scenario?

• A. Increase max.poll.interval.ms to 600000
• B. Increase heartbeat.interval.ms to 600000
• C. Increase session.timeout.ms to 600000
• D. Add consumers to the consumer group and kill them right away

Answer: A

Explanation:
Here, we need to change the setting max.poll.interval.ms (default 300000) to its double in order to tell Kafka a consumer should be considered dead if the consumer only if it hasn't called the .poll() method in 10 minutes instead of 5.

NEW QUESTION 17
What is not a valid authentication mechanism in Kafka?

• A. SASL/GSSAPI
• B. SASL/SCRAM
• C. SAML
• D. SSL

Answer: C

Explanation:
Learn more about security herehttps://kafka.apache.org/documentation/#security

NEW QUESTION 18
Select all that applies (select THREE)

• A. min.insync.replicas is a producer setting
• B. acks is a topic setting
• C. acks is a producer setting
• D. min.insync.replicas is a topic setting
• E. min.insync.replicas matters regardless of the values of acks
• F. min.insync.replicas only matters if acks=all

Answer: CDF

Explanation:
acks is a producer setting min.insync.replicas is a topic or broker setting and is only effective when acks=all

NEW QUESTION 19
What isn't a feature of the Confluent schema registry?

• A. Store avro data
• B. Enforce compatibility rules
• C. Store schemas

Answer: A

Explanation:
Data is stored on brokers.

NEW QUESTION 20
......