[Mar 01, 2022] CCDAK Dumps Full Questions - Exam Study Guide
Confluent Certified Developer Free Certification Exam Material from PassTorrent with 150 Questions
NEW QUESTION 88
What's a Kafka partition made of?
- A. One file and one index
- B. One file and two indexes per segment
- C. One file
- D. One file and two indexes
Answer: B
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 89
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. base64 encoded data, it will need to decode it
- B. "test_binary" will receive
- C. json data
- D. binary data
- E. avro data
Answer: D
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 90
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 Kafka Brokers
- C. As an in-memory plugin on your Kafka Connect Workers
- D. As an in-memory plugin on your Zookeeper cluster
Answer: A
Explanation:
Schema registry is a separate application that provides RESTful interface for storing and retrieving Avro schemas.
NEW QUESTION 91
To get acknowledgement of writes to only the leader partition, we need to use the config...
- A. acks=0
- B. acks=1
- C. acks=all
Answer: B
Explanation:
Producers can set acks=1 to get acknowledgement from partition leader only.
NEW QUESTION 92
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. 0
- B. 1
- C. 2
- D. 3
Answer: C
Explanation:
You cannot have more sink tasks (= consumers) than the number of partitions, so 2.
NEW QUESTION 93
Partition leader election is done by
- A. Vote amongst the brokers
- B. The consumers
- C. The Kafka Broker that is the Controller
- D. Zookeeper
Answer: D
Explanation:
The Controller is a broker that is responsible for electing partition leaders
NEW QUESTION 94
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. The Kafka ACL does not allow another machine IP
- B. You cannot copy a producer application from one machine to another
- C. Broker configuration needs to be changed to allow a different producer
- D. The Kafka Broker needs to be rebooted
Answer: A
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 95
An ecommerce website maintains two topics - a high volume "purchase" topic with 5 partitions and low volume "customer" topic with 3 partitions. You would like to do a stream-table join of these topics. How should you proceed?
- A. Repartition the purchase topic to have 3 partitions
- B. Do a KStream / KTable join after a repartition step
- C. Repartition customer topic to have 5 partitions
- D. Model customer as a GlobalKTable
Answer: D
Explanation:
In case of KStream-KStream join, both need to be co-partitioned. This restriction is not applicable in case of join with GlobalKTable, which is the most efficient here.
NEW QUESTION 96
A consumer has auto.offset.reset=latest, and the topic partition currently has data for offsets going from 45 to 2311. The consumer group never committed offsets for the topic before. Where will the consumer read from?
- A. offset 45
- B. it will crash
- C. offset 2311
- D. offset 0
Answer: C
Explanation:
Latest means that data retrievals will start from where the offsets currently end
NEW QUESTION 97
What Java library is KSQL based on?
- A. Kafka Connect
- B. Schema Registry
- C. Kafka Streams
- D. REST Proxy
Answer: C
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 98
What isn't a feature of the Confluent schema registry?
- A. Enforce compatibility rules
- B. Store avro data
- C. Store schemas
Answer: B
Explanation:
Data is stored on brokers.
NEW QUESTION 99
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. 0
- B. 1
- C. 2
- D. 3
Answer: C
Explanation:
we have two tables, so the max number of tasks is 2
NEW QUESTION 100
A topic has three replicas and you set min.insync.replicas to 2. If two out of three replicas are not available, what happens when a produce request with acks=all is sent to broker?
- A. Produce request is honored with single in-sync replica
- B. Produce request will block till one of the two unavailable partition is available again.
- C. NotEnoughReplicasException will be returned
Answer: C
Explanation:
With this configuration, a single in-sync replica becomes read-only. Produce request will receive NotEnoughReplicasException.
NEW QUESTION 101
In Avro, removing a field that does not have a default is a __ schema evolution
- A. forward
- B. full
- C. backward
- D. breaking
Answer: C
Explanation:
Clients with new schema will be able to read records saved with old schema.
NEW QUESTION 102
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 session.timeout.ms to 600000
- B. Add consumers to the consumer group and kill them right away
- C. Increase heartbeat.interval.ms to 600000
- D. Increase max.poll.interval.ms to 600000
Answer: D
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 103
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=false
- B. Any of the replicas
- C. Preferred leader broker if it is in-sync and auto.leader.rebalance.enable=true
- D. An in-sync replica
Answer: B,D
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 104
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, and an older client can talk to a newer broker
- C. A newer client can't talk to a newer broker, but an older client can talk to a newer broker
- D. A newer client can talk to a newer broker, but an older client cannot talk to a newer broker
Answer: B
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 105
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. None
- B. 0
- C. 1
- D. 2
Answer: C
Explanation:
One consumer per partition assignment will keep 5 consumers idle.
NEW QUESTION 106
Which of the following is not an Avro primitive type?
- A. int
- B. date
- C. string
- D. null
- E. long
Answer: B
Explanation:
date is a logical type
NEW QUESTION 107
StreamsBuilder builder = new StreamsBuilder();
KStream<String, String> textLines = builder.stream("word-count-input"); KTable<String, Long> wordCounts = textLines
.mapValues(textLine -> textLine.toLowerCase())
.flatMapValues(textLine -> Arrays.asList(textLine.split("\W+")))
.selectKey((key, word) -> word)
.groupByKey()
.count(Materialized.as("Counts"));
wordCounts.toStream().to("word-count-output", Produced.with(Serdes.String(), Serdes.Long())); builder.build(); What is an adequate topic configuration for the topic word-count-output?
- A. cleanup.policy=compact
- B. max.message.bytes=10000000
- C. compression.type=lz4
- D. cleanup.policy=delete
Answer: A
Explanation:
Result is aggregated into a table with key as the unique word and value its frequency. We have to enable log compaction for this topic to align the topic's cleanup policy with KTable semantics.
NEW QUESTION 108
......
Dumps Brief Outline Of The CCDAK Exam: https://www.passtorrent.com/CCDAK-latest-torrent.html
Use Real CCDAK - 100% Cover Real Exam Questions: https://drive.google.com/open?id=1lAZUxM1x6oCLfFn4DSScozRQUvNrCFSZ