Far Out Confluent Certified Developer For Apache Kafka Certification Examination CCDAK Brain Dumps

NEW QUESTION 1
What's is true about Kafka brokers and clients from version 0.10.2 onwards?

• A. Clients and brokers must have the exact same version to be able to communicate
• B. A newer client can talk to a newer broker, but an older client cannot talk to a newer broker
• C. A newer client can talk to a newer broker, and an older client can talk to a newer broker
• D. A newer client can't talk to a newer broker, but an older client can talk to a newer broker

Answer: C

Explanation:
Kafka's new bidirectional client compatibility introduced in 0.10.2 allows this. Read more herehttps://www.confluent.io/blog/upgrading-apache-kafka-clients-just-got-easier/

NEW QUESTION 2
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 3
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 4
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 5
By default, which replica will be elected as a partition leader? (select two)

• A. Preferred leader broker if it is in-sync and auto.leader.rebalance.enable=true
• B. Any of the replicas
• C. Preferred leader broker if it is in-sync and auto.leader.rebalance.enable=false
• D. An in-sync replica

Answer: BD

Explanation:
Preferred leader is a broker that was leader when topic was created. It is preferred because when partitions are first created, the leaders are balanced between brokers. Otherwise, any of the in-sync replicas (ISR) will be elected leader, as long as unclean.leader.election=false (by default)

NEW QUESTION 6
In Avro, removing or adding a field that has a default is a schema evolution

• A. full
• B. backward
• C. breaking
• D. forward

Answer: A

Explanation:
Clients with new schema will be able to read records saved with old schema and clients with old schema will be able to read records saved with new schema.

NEW QUESTION 7
How do you create a topic named test with 3 partitions and 3 replicas using the Kafka CLI?

• A. bin/kafka-topics.sh --create --broker-list localhost:9092 --replication-factor 3 --partitions 3--topic test
• B. bin/kafka-topics-create.sh --zookeeper localhost:9092 --replication-factor 3 --partitions 3--topic test
• C. bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 3 -- partitions 3 --topic test
• D. bin/kafka-topics.sh --create --bootstrap-server localhost:2181 --replication-factor 3 -- partitions 3 --topic test

Answer: C

Explanation:
As of Kafka 2.3, the kafka-topics.sh command can take --bootstrap-server localhost:9092 as an argument. You could also use the (now deprecated) option of --zookeeper localhost:2181.

NEW QUESTION 8
The rule "same key goes to the same partition" is true unless...

• A. the number of producer changes
• B. the number of kafka broker changes
• C. the number of partition changes
• D. the replication factor changes

Answer: C

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 9
Which of the following Kafka Streams operators are stateless? (select all that apply)

• A. map
• B. filter
• C. flatmap
• D. branch
• E. groupBy
• F. aggregate

Answer: ABCDE

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

NEW QUESTION 10
What's a Kafka partition made of?

• A. One file and one index
• B. One file
• C. One file and two indexes per segment
• D. One file and two indexes

Answer: C

Explanation:
Kafka partitions are made of segments (usually each segment is 1GB), and each segment has two corresponding indexes (offset index and time index)

NEW QUESTION 11
CORRECT TEXT
If I want to send binary data through the REST proxy to topic "test_binary", it needs to be base64 encoded. A consumer connecting directly into the Kafka topic

• A. "test_binary" will receive
• B. binary data
• C. avro data
• D. json data
• E. base64 encoded data, it will need to decode it

Answer: B

Explanation:
On the producer side, after receiving base64 data, the REST Proxy will convert it into bytes and then send that bytes payload to Kafka. Therefore consumers reading directly from Kafka will receive binary data.

NEW QUESTION 12
When using the Confluent Kafka Distribution, where does the schema registry reside?

• A. As a separate JVM component
• B. As an in-memory plugin on your Zookeeper cluster
• C. As an in-memory plugin on your Kafka Brokers
• D. As an in-memory plugin on your Kafka Connect Workers

Answer: A

Explanation:
Schema registry is a separate application that provides RESTful interface for storing and retrieving Avro schemas.

NEW QUESTION 13
A kafka topic has a replication factor of 3 and min.insync.replicas setting of 2. How many brokers can go down before a producer with acks=1 can't produce?

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

Answer: D

Explanation:
min.insync.replicas does not impact producers when acks=1 (only when acks=all)

NEW QUESTION 14
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 15
To continuously export data from Kafka into a target database, I should use

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

Answer: C

Explanation:
Kafka Connect Sink is used to export data from Kafka to external databases and Kafka Connect Source is used to import from external databases into Kafka.

NEW QUESTION 16
You have a Zookeeper cluster that needs to be able to withstand the loss of 2 servers and still be able to function. What size should your Zookeeper cluster have?

• A. 4
• B. 5
• C. 2
• D. 3
• E. 6

Answer: B

Explanation:
Your Zookeeper cluster needs to have an odd number of servers, and must maintain a majority of servers up to be able to vote. Therefore, a 2N+1 zookeeper cluster can survive to N zookeeper being down, so here the right answer is N=2, 2*N+1=5

NEW QUESTION 17
We want the average of all events in every five-minute window updated every minute. What kind of Kafka Streams window will be required on the stream?

• A. Session window
• B. Tumbling window
• C. Sliding window
• D. Hopping window

Answer: D

Explanation:
A hopping window is defined by two propertiesthe window's size and its advance interval (aka "hop"), e.g., a hopping window with a size 5 minutes and an advance interval of 1 minute.

NEW QUESTION 18
......