[May-2022] Updated Confluent Certified Developer CCDAK Exam Questions BUNDLE PACK
Master The Confluent Content CCDAK EXAM DUMPS WITH GUARANTEED SUCCESS!
NEW QUESTION 27
Compaction is enabled for a topic in Kafka by setting log.cleanup.policy=compact. What is true about log compaction?
- A. Kafka automatically de-duplicates incoming messages based on key hashes
- B. After cleanup, only one message per key is retained with the first value
- C. Each message stored in the topic is compressed
- D. After cleanup, only one message per key is retained with the latest value
Answer: D
Explanation:
Compaction changes the offset of messages
Explanation:
Log compaction retains at least the last known value for each record key for a single topic partition. All compacted log offsets remain valid, even if record at offset has been compacted away as a consumer will get the next highest offset.
NEW QUESTION 28
Which of the following setting increases the chance of batching for a Kafka Producer?
- A. Increase batch.size
- B. Increase the number of producer threads
- C. Increase linger.ms
- D. Increase message.max.bytes
Answer: C
Explanation:
linger.ms forces the producer to wait to send messages, hence increasing the chance of creating batches
NEW QUESTION 29
When auto.create.topics.enable is set to true in Kafka configuration, what are the circumstances under which a Kafka broker automatically creates a topic? (select three)
- A. Consumer reads message from a topic
- B. Producer sends message to a topic
- C. Client alters number of partitions of a topic
- D. Client requests metadata for a topic
Answer: A,B,D
Explanation:
A kafka broker automatically creates a topic under the following circumstances- When a producer starts writing messages to the topic - When a consumer starts reading messages from the topic - When any client requests metadata for the topic
NEW QUESTION 30
What isn't an internal Kafka Connect topic?
- A. connect-configs
- B. connect-status
- C. connect-jars
- D. connect-offsets
Answer: C
Explanation:
connect-configs stores configurations, connect-status helps to elect leaders for connect, and connect-offsets store source offsets for source connectors
NEW QUESTION 31
What is not a valid authentication mechanism in Kafka?
- A. SASL/GSSAPI
- B. SSL
- C. SASL/SCRAM
- D. SAML
Answer: D
Explanation:
Learn more about security herehttps://kafka.apache.org/documentation/#security
NEW QUESTION 32
In Avro, adding a field to a record without default is a __ schema evolution
- A. backward
- B. full
- C. forward
- D. breaking
Answer: C
Explanation:
Clients with old schema will be able to read records saved with new schema.
NEW QUESTION 33
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. A new leader for the partition will be elected
- B. Data will be returned from the remaining in-sync replica
- C. An empty message will be returned
- D. NotEnoughReplicasException will be returned
Answer: B
Explanation:
With this configuration, a single in-sync replica is still readable, but not writeable if the producer using acks=all
NEW QUESTION 34
How do Kafka brokers ensure great performance between the producers and consumers? (select two)
- A. It does not transform the messages
- B. It compresses the messages as it writes to the disk
- C. It leverages zero-copy optimisations to send data straight from the page-cache
- D. It buffers the messages on disk, and sends messages from the disk reads
- E. It transforms the messages into a binary format
Answer: A,C
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 35
You want to perform table lookups against a KTable everytime a new record is received from the KStream. What is the output of KStream-KTable join?
- A. KTable
- B. Kstream
- C. You choose between KStream or KTable
- D. GlobalKTable
Answer: B
Explanation:
Here KStream is being processed to create another KStream.
NEW QUESTION 36
Select all the way for one consumer to subscribe simultaneously to the following topics - topic.history, topic.sports, topic.politics? (select two)
- A. consumer.subscribePrefix("topic.");
- B. consumer.subscribe(Pattern.compile("topic\..*"));
- C. consumer.subscribe(Arrays.asList("topic.history", "topic.sports", "topic.politics"));
- D. consumer.subscribe("topic.history"); consumer.subscribe("topic.sports"); consumer.subscribe("topic.politics");
Answer: B,C
Explanation:
Multiple topics can be passed as a list or regex pattern.
NEW QUESTION 37
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 38
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. Throws IllegalStateException
- B. This works fine. subscribe() will subscribe to the topic and assign() will assign partitions to the consumer.
Answer: A
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 39
Which of the following statements are true regarding the number of partitions of a topic?
- A. We can add partitions in a topic by adding a broker to the cluster
- B. We can remove partitions in a topic using the kafka-topics.sh command
- 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. The number of partitions in a topic cannot be altered
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 40
Where are KSQL-related data and metadata stored?
- A. Kafka Topics
- B. Schema Registry
- C. PostgreSQL database
- D. Zookeeper
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 41
Select all that applies (select THREE)
- A. min.insync.replicas is a producer setting
- B. min.insync.replicas is a topic setting
- C. acks is a producer setting
- D. min.insync.replicas matters regardless of the values of acks
- E. min.insync.replicas only matters if acks=all
- F. acks is a topic setting
Answer: B,C,E
Explanation:
acks is a producer setting min.insync.replicas is a topic or broker setting and is only effective when acks=all
NEW QUESTION 42
Which of the following Kafka Streams operators are stateful? (select all that apply)
- A. joining
- B. peek
- C. count
- D. flatmap
- E. aggregate
- F. reduce
Answer: A,C,E,F
Explanation:
Seehttps://kafka.apache.org/20/documentation/streams/developer-guide/dsl-api.html#stateful-transformations
NEW QUESTION 43
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. 168 minutes
- D. Broker will not start due to bad configuration
Answer: A
Explanation:
If more than one similar config is specified, the smaller unit size will take precedence.
NEW QUESTION 44
......
Pass Confluent CCDAK Exam – Experts Are Here To Help You: https://examkiller.itexamreview.com/CCDAK-valid-exam-braindumps.html
