New CCDAK Test Materials & Valid CCDAK Test Engine
CCDAK Updated Exam Dumps [2022] Practice Valid Exam Dumps Question
NEW QUESTION 51
How will you read all the messages from a topic in your KSQL query?
- A. KSQL reads from the end of a topic. This cannot be changed.
- B. Use KSQL CLI to set auto.offset.reset property to earliest
- C. KSQL reads from the beginning of a topic, by default.
Answer: B
Explanation:
Consumers can set auto.offset.reset property to earliest to start consuming from beginning. For KSQL, SET 'auto.offset.reset'='earliest';
NEW QUESTION 52
What Java library is KSQL based on?
- A. Schema Registry
- B. Kafka Streams
- C. Kafka Connect
- D. REST Proxy
Answer: B
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 53
A consumer wants to read messages from a specific partition of a topic. How can this be achieved?
- A. Call assign() passing a Collection of TopicPartitions as the argument
- B. Call subscribe() passing TopicPartition as the argument
- C. Call subscribe(String topic, int partition) passing the topic and partition number as the arguments
Answer: A
Explanation:
assign() can be used for manual assignment of a partition to a consumer, in which case subscribe() must not be used. Assign() takes a collection of TopicPartition object as an argument https://kafka.apache.org/23/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#assign-java.util.Collection-
NEW QUESTION 54
Which of the following errors are retriable from a producer perspective? (select two)
- A. TOPIC_AUTHORIZATION_FAILED
- B. NOT_LEADER_FOR_PARTITION
- C. NOT_ENOUGH_REPLICAS
- D. INVALID_REQUIRED_ACKS
- E. MESSAGE_TOO_LARGE
Answer: B,C
Explanation:
Both of these are retriable errors, others non-retriable errors. See the full list of errors and their "retriable" status herehttps://kafka.apache.org/protocol#protocol_error_codes
NEW QUESTION 55
If a topic has a replication factor of 3...
- A. Each partition will live on 4 different brokers
- B. Each partition will live on 3 different brokers
- C. 3 replicas of the same data will live on 1 broker
- D. Each partition will live on 2 different brokers
Answer: B
Explanation:
Replicas are spread across available brokers, and each replica = one broker. RF 3 = 3 brokers
NEW QUESTION 56
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. C1 will be assigned partitions 0 and 1 from T1 and T2, C2 will be assigned partition 2 from T1 and T2.
- B. 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.
- C. All consumers will read from all partitions
- D. Two consumers cannot read from two topics at the same time
Answer: B
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 57
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. Tumbling window
- B. Session 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 58
The Controller is a broker that is... (select two)
- A. is responsible for partition leader election
- B. elected by broker majority
- C. is responsible for consumer group rebalances
- D. elected by Zookeeper ensemble
Answer: A,D
Explanation:
Controller is a broker that in addition to usual broker functions is responsible for partition leader election. The election of that broker happens thanks to Zookeeper and at any time only one broker can be a controller
NEW QUESTION 59
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. 0
- B. 1
- C. 2
- D. 3
- E. 4
Answer: D
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 60
is KSQL ANSI SQL compliant?
- A. No
- B. Yes
Answer: A
Explanation:
KSQL is not ANSI SQL compliant, for now there are no defined standards on streaming SQL languages
NEW QUESTION 61
If I produce to a topic that does not exist, and the broker setting auto.create.topic.enable=true, what will happen?
- A. Kafka will automatically create the topic with num.partitions=#of brokers and replication.factor=3
- B. Kafka will automatically create the topic with 1 partition and 1 replication factor
- C. Kafka will automatically create the topic with the broker settings num.partitions and default.replication.factor
- D. Kafka will automatically create the topic with the indicated producer settings num.partitions and default.replication.factor
Answer: C
Explanation:
The broker settings comes into play when a topic is auto created
NEW QUESTION 62
In Kafka, every broker... (select three)
- A. contains only a subset of the topics and the partitions
- B. contains all the topics and all the partitions
- C. is a controller
- D. knows the metadata for the topics and partitions it has on its disk
- E. knows all the metadata for all topics and partitions
- F. is a bootstrap broker
Answer: A,E,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 63
How will you find out all the partitions where one or more of the replicas for the partition are not in-sync with the leader?
- A. kafka-topics.sh --broker-list localhost:9092 --describe --under-replicated-partitions
- B. kafka-topics.sh --zookeeper localhost:2181 --describe --under-replicated-partitions
- C. kafka-topics.sh --bootstrap-server localhost:9092 --describe --unavailable- partitions
- D. kafka-topics.sh --zookeeper localhost:2181 --describe --unavailable- partitions
Answer: B
NEW QUESTION 64
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 stream
- C. Purchase as stream, Product as table, Customer as table
- D. Purchase as table, Product as table, Customer as table
Answer: C
Explanation:
Mostly-static data is modeled as a table whereas business transactions should be modeled as a stream.
NEW QUESTION 65
Which Kafka CLI should you use to consume from a topic?
- A. kafka-consumer-groups
- B. kafka-console-consumer
- C. kafka-console
- D. kafka-topics
Answer: B
Explanation:
Examplekafka-console-consumer --bootstrap-server 127.0.0.1:9092 --topic test --from-beginning
NEW QUESTION 66
......
CCDAK Sample with Accurate & Updated Questions: https://pass4sure.actual4cert.com/CCDAK-pass4sure-vce.html