[Mar 18, 2022] Valid CCDAK Test Answers & Confluent CCDAK Exam PDF
Realistic CCDAK Exam Dumps with Accurate & Updated Questions
NEW QUESTION 16
How will you set the retention for the topic named my-topic to 1 hour?
- A. Set the broker config log.retention.ms to 3600000
- B. Set the consumer config retention.ms to 3600000
- C. Set the topic config retention.ms to 3600000
- D. Set the producer config retention.ms to 3600000
Answer: C
Explanation:
retention.ms can be configured at topic level while creating topic or by altering topic. It shouldn't be set at the broker level (log.retention.ms) as this would impact all the topics in the cluster, not just the one we are interested in
NEW QUESTION 17
A producer application was sending messages to a partition with a replication factor of 2 by connecting to Broker 1 that was hosting partition leader. If the Broker 1 goes down, what will happen?
- A. The topic will be unavailable
- B. The producer will stop working
- C. The producer will automatically produce to the broker that has been elected leader
Answer: C
Explanation:
Once the client connects to any broker, it is connected to the entire cluster and in case of leadership changes, the clients automatically do a Metadata Request to an available broker to find out who is the new leader for the topic. Hence the producer will automatically keep on producing to the correct Kafka Broker
NEW QUESTION 18
When is the onCompletion() method called?
private class ProducerCallback implements Callback {
@Override
public void onCompletion(RecordMetadata recordMetadata, Exception e) {
if (e != null) {
e.printStackTrace();
}
}
}
ProducerRecord<String, String> record =
new ProducerRecord<>("topic1", "key1", "value1");
producer.send(record, new ProducerCallback());
- A. When send() method is called
- B. When message is serialized successfully
- C. When the message is partitioned and batched successfully
- D. When the broker response is received
Answer: D
Explanation:
Callback is invoked when a broker response is received.
NEW QUESTION 19
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 20
There are five brokers in a cluster, a topic with 10 partitions and replication factor of 3, and a quota of producer_bytes_rate of 1 MB/sec has been specified for the client. What is the maximum throughput allowed for the client?
- A. 0.33 MB/s
- B. 5 MB/s
- C. 10 MB/s
- D. 1 MB/s
Answer: B
Explanation:
Each producer is allowed to produce @ 1MB/s to a broker. Max throughput 5 * 1MB, because we have 5 brokers.
NEW QUESTION 21
What client protocol is supported for the schema registry? (select two)
- A. Websocket
- B. HTTP
- C. JDBC
- D. HTTPS
- E. SASL
Answer: B,D
Explanation:
clients can interact with the schema registry using the HTTP or HTTPS interface
NEW QUESTION 22
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 23
Which of the following is true regarding thread safety in the Java Kafka Clients?
- A. One Producer needs to be run in one thread
- B. One Producer can be safely used in multiple threads
- C. One Consumer needs to run in one thread
- D. One Consumer can be safely used in multiple threads
Answer: B,C
Explanation:
KafkaConsumer is not thread-safe, KafkaProducer is thread safe.
NEW QUESTION 24
An ecommerce wesbite sells some custom made goods. What's the natural way of modeling this data in Kafka streams?
- A. Purchase as stream, Product as stream, Customer as stream
- B. Purchase as stream, Product as table, Customer as table
- C. Purchase as table, Product as table, Customer as table
- D. Purchase as stream, Product as table, Customer as stream
Answer: B
Explanation:
Mostly-static data is modeled as a table whereas business transactions should be modeled as a stream.
NEW QUESTION 25
If a topic has a replication factor of 3...
- A. Each partition will live on 4 different brokers
- B. 3 replicas of the same data will live on 1 broker
- C. Each partition will live on 2 different brokers
- D. Each partition will live on 3 different brokers
Answer: D
Explanation:
Replicas are spread across available brokers, and each replica = one broker. RF 3 = 3 brokers
NEW QUESTION 26
In Kafka Streams, by what value are internal topics prefixed by?
- A. tasks-<number>
- B. group.id
- C. application.id
- D. kafka-streams-
Answer: C
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 27
To transform data from a Kafka topic to another one, I should use
- A. Kafka Connect Sink
- B. Consumer + Producer
- C. Kafka Streams
- D. Kafka Connect Source
Answer: C
Explanation:
Kafka Streams is a library for building streaming applications, specifically applications that transform input Kafka topics into output Kafka topics
NEW QUESTION 28
The kafka-console-consumer CLI, when used with the default options
- A. always uses the same group id
- B. uses a random group id
- C. does not use a group id
Answer: B
Explanation:
If a group is not specified, the kafka-console-consumer generates a random consumer group.
NEW QUESTION 29
There are two consumers C1 and C2 belonging to the same group G subscribed to topics T1 and T2. Each of the topics has 3 partitions. How will the partitions be assigned to consumers with Partition Assigner being Round Robin Assigner?
- A. Two consumers cannot read from two topics at the same time
- B. All consumers will read from all partitions
- C. C1 will be assigned partitions 0 and 2 from T1 and partition 1 from T2. C2 will have partition 1 from T1 and partitions 0 and 2 from T2.
- D. C1 will be assigned partitions 0 and 1 from T1 and T2, C2 will be assigned partition 2 from T1 and T2.
Answer: C
Explanation:
The correct option is the only one where the two consumers share an equal number of partitions amongst the two topics of three partitions. An interesting article to read ishttps://medium.com/@anyili0928/what-i-have-learned-from-kafka-partition-assignment-strategy-799fdf15d3ab
NEW QUESTION 30
Your topic is log compacted and you are sending a message with the key K and value null. What will happen?
- A. The producer will throw a Runtime exception
- B. The broker will delete the message with the key K and null value only upon cleanup
- C. The broker will delete all messages with the key K upon cleanup
- D. The message will get ignored by the Kafka broker
Answer: C
Explanation:
Sending a message with the null value is called a tombstone in Kafka and will ensure the log compacted topic does not contain any messages with the key K upon compaction
NEW QUESTION 31
......
CCDAK Exam Dumps - PDF Questions and Testing Engine: https://www.dumpstests.com/CCDAK-latest-test-dumps.html
CCDAK Dumps - The Sure Way To Pass Exam: https://drive.google.com/open?id=1s0pOnwEPGd3nyq0ydFX9TEyOTsVx7HL-