[Oct-2022] Updated Confluent Certified Developer CCDAK Exam Questions BUNDLE PACK
Master The Confluent Content CCDAK EXAM DUMPS WITH GUARANTEED SUCCESS!
NEW QUESTION 23
What is a generic unique id that I can use for messages I receive from a consumer?
- A. topic + partition + offset
- B. topic + timestamp
- C. topic + partition + timestamp
Answer: A
Explanation:
(Topic,Partition,Offset) uniquely identifies a message in Kafka
NEW QUESTION 24
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. BytesInPerSec
- B. MessagesInPerSec
- C. records-lag-max
- D. UnderReplicatedPartitions
Answer: C
Explanation:
This metric shows the current lag (number of messages behind the broker)
NEW QUESTION 25
Which of the following setting increases the chance of batching for a Kafka Producer?
- A. Increase batch.size
- B. Increase linger.ms
- C. Increase the number of producer threads
- D. Increase message.max.bytes
Answer: B
Explanation:
linger.ms forces the producer to wait to send messages, hence increasing the chance of creating batches
NEW QUESTION 26
Select the Kafka Streams joins that are always windowed joins.
- A. KStream-KTable join
- B. KStream-KStream join
- C. KStream-GlobalKTable
- D. KTable-KTable join
Answer: B
Explanation:
Seehttps://docs.confluent.io/current/streams/developer-guide/dsl-api.html#joining
NEW QUESTION 27
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. 40 sec
- C. 10 sec
- D. 2000 ms
Answer: B
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 28
Where are the ACLs stored in a Kafka cluster by default?
- A. Inside the Zookeeper's data directory
- B. Inside the broker's data directory
- C. In Kafka topic __kafka_acls
- D. Under Zookeeper node /kafka-acl/
Answer: B
Explanation:
ACLs are stored in Zookeeper node /kafka-acls/ by default.
NEW QUESTION 29
Two consumers share the same group.id (consumer group id). Each consumer will
- A. Read mutually exclusive offsets blocks on all the partitions
- B. Read all data from all partitions
- C. Read all the data on mutual exclusive partitions
Answer: C
Explanation:
Each consumer is assigned a different partition of the topic to consume.
NEW QUESTION 30
To prevent network-induced duplicates when producing to Kafka, I should use
- A. enable.idempotence=true
- B. max.in.flight.requests.per.connection=1
- C. retries=200000
- D. batch.size=1
Answer: A
Explanation:
Producer idempotence helps prevent the network introduced duplicates. More details herehttps://cwiki.apache.org/confluence/display/KAFKA/Idempotent+Producer
NEW QUESTION 31
Once sent to a topic, a message can be modified
- A. No
- B. Yes
Answer: A
Explanation:
Kafka logs are append-only and the data is immutable
NEW QUESTION 32
In Kafka, every broker... (select three)
- A. knows the metadata for the topics and partitions it has on its disk
- B. is a controller
- C. contains only a subset of the topics and the partitions
- D. knows all the metadata for all topics and partitions
- E. contains all the topics and all the partitions
- F. is a bootstrap broker
Answer: C,D,F
Explanation:
Kafka topics are divided into partitions and spread across brokers. Each brokers knows about all the metadata and each broker is a bootstrap broker, but only one of them is elected controller
NEW QUESTION 33
Kafka is configured with following parameters - log.retention.hours = 168 log.retention.minutes = 168 log.retention.ms = 168 How long will the messages be retained for?
- A. 168 ms
- B. 168 hours
- C. Broker will not start due to bad configuration
- D. 168 minutes
Answer: A
Explanation:
If more than one similar config is specified, the smaller unit size will take precedence.
NEW QUESTION 34
A consumer wants to read messages from partitions 0 and 1 of a topic topic1. Code snippet is shown below.
consumer.subscribe(Arrays.asList("topic1"));
List<TopicPartition> pc = new ArrayList<>();
pc.add(new PartitionTopic("topic1", 0));
pc.add(new PartitionTopic("topic1", 1));
consumer.assign(pc);
- A. This works fine. subscribe() will subscribe to the topic and assign() will assign partitions to the consumer.
- B. Throws IllegalStateException
Answer: B
Explanation:
subscribe() and assign() cannot be called by the same consumer, subscribe() is used to leverage the consumer group mechanism, while assign() is used to manually control partition assignment and reads assignment
NEW QUESTION 35
How do Kafka brokers ensure great performance between the producers and consumers? (select two)
- A. It compresses the messages as it writes to the disk
- B. It does not transform the messages
- C. It buffers the messages on disk, and sends messages from the disk reads
- D. It transforms the messages into a binary format
- E. It leverages zero-copy optimisations to send data straight from the page-cache
Answer: B,E
Explanation:
Kafka transfers data with zero-copy and sends the raw bytes it receives from the producer straight to the consumer, leveraging the RAM available as page cache
NEW QUESTION 36
A producer just sent a message to the leader broker for a topic partition. The producer used acks=1 and therefore the data has not yet been replicated to followers. Under which conditions will the consumer see the message?
- A. Right away
- B. Never, the produce request will fail
- C. When the message has been fully replicated to all replicas
- D. When the high watermark has advanced
Answer: D
Explanation:
The high watermark is an advanced Kafka concept, and is advanced once all the ISR replicates the latest offsets. A consumer can only read up to the value of the High Watermark (which can be less than the highest offset, in the case of acks=1)
NEW QUESTION 37
You have a consumer group of 12 consumers and when a consumer gets killed by the process management system, rather abruptly, it does not trigger a graceful shutdown of your consumer. Therefore, it takes up to 10 seconds for a rebalance to happen. The business would like to have a 3 seconds rebalance time. What should you do? (select two)
- A. Decrease session.timeout.ms
- B. Increase heartbeat.interval.ms
- C. increase max.poll.interval.ms
- D. decrease max.poll.interval.ms
- E. Decrease heartbeat.interval.ms
- F. Increase session.timeout.ms
Answer: A,C
Explanation:
session.timeout.ms must be decreased to 3 seconds to allow for a faster rebalance, and the heartbeat thread must be quicker, so we also need to decrease heartbeat.interval.ms
NEW QUESTION 38
In Avro, adding an element to an enum without a default is a __ schema evolution
- A. breaking
- B. forward
- C. full
- D. backward
Answer: A
Explanation:
Since Confluent 5.4.0, Avro 1.9.1 is used. Since default value was added to enum complex type , the schema resolution changed from:
(<1.9.1) if both are enums:** if the writer's symbol is not present in the reader's enum, then an error is signalled. **(>=1.9.1) if both are enums:
if the writer's symbol is not present in the reader's enum and the reader has a default value, then that value is used, otherwise an error is signalled.
NEW QUESTION 39
What is the risk of increasing max.in.flight.requests.per.connection while also enabling retries in a producer?
- A. At least once delivery is not guaranteed
- B. Message order not preserved
- C. Reduce throughput
- D. Less resilient
Answer: B
Explanation:
Some messages may require multiple retries. If there are more than 1 requests in flight, it may result in messages received out of order. Note an exception to this rule is if you enable the producer settingenable.idempotence=true which takes care of the out of ordering case on its own. Seehttps://issues.apache.org/jira/browse/KAFKA-5494
NEW QUESTION 40
What data format isn't natively available with the Confluent REST Proxy?
- A. avro
- B. json
- C. binary
- D. protobuf
Answer: D
Explanation:
Protocol buffers isn't a natively supported type for the Confluent REST Proxy, but you may use the binary format instead
NEW QUESTION 41
To enhance compression, I can increase the chances of batching by using
- A. max.message.size=10MB
- B. linger.ms=20
- C. acks=all
- D. batch.size=65536
Answer: B
Explanation:
linger.ms forces the producer to wait before sending messages, hence increasing the chance of creating batches that can be heavily compressed.
NEW QUESTION 42
Which actions will trigger partition rebalance for a consumer group? (select three)
- A. Increase partitions of a topic
- B. Add a new consumer to consumer group
- C. A consumer in a consumer group shuts down
- D. Remove a broker from the cluster
Answer: A,B,C
Explanation:
Add a broker to the cluster
Explanation:
Rebalance occurs when a new consumer is added, removed or consumer dies or paritions increased.
NEW QUESTION 43
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 consume request is sent to broker?
- A. Data will be returned from the remaining in-sync replica
- B. NotEnoughReplicasException will be returned
- C. A new leader for the partition will be elected
- D. An empty message will be returned
Answer: A
Explanation:
With this configuration, a single in-sync replica is still readable, but not writeable if the producer using acks=all
NEW QUESTION 44
In Java, Avro SpecificRecords classes are
- A. written manually by the programmer
- B. automatically generated from an Avro Schema
- C. automatically generated from an Avro Schema + a Maven / Gradle Plugin
Answer: C
Explanation:
SpecificRecord is created from generated record classes
NEW QUESTION 45
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 46
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=all can't produce?
- A. 0
- B. 1
- C. 2
- D. 3
Answer: B
Explanation:
acks=all and min.insync.replicas=2 means we must have at least 2 brokers up for the partition to be available
NEW QUESTION 47
......
Pass Confluent CCDAK Exam – Experts Are Here To Help You: https://www.examslabs.com/Confluent/Confluent-Certified-Developer/best-CCDAK-exam-dumps.html
Get Latest Confluent Certified Developer CCDAK Practice Test For Quick Preparation: https://drive.google.com/open?id=1m6KPtoJGm-jEPKuC59zvISzOBpfAC2_C