Current CCDAK Exam Dumps [2022] Complete Confluent Exam Smoothly
CCDAK Premium PDF & Test Engine Files with 150 Questions & Answers
NEW QUESTION 72
If you enable an SSL endpoint in Kafka, what feature of Kafka will be lost?
- A. Cross-cluster mirroring
- B. Support for Avro format
- C. Exactly-once delivery
- D. Zero copy
Answer: D
Explanation:
With SSL, messages will need to be encrypted and decrypted, by being first loaded into the JVM, so you lose the zero copy optimization. See more information herehttps://twitter.com/ijuma/status/1161303431501324293?s=09
NEW QUESTION 73
What Java library is KSQL based on?
- A. REST Proxy
- B. Schema Registry
- C. Kafka Streams
- D. Kafka Connect
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 74
If I want to send binary data through the REST proxy, it needs to be base64 encoded. Which component needs to encode the binary data into base 64?
- A. The Producer
- B. Zookeeper
- C. The REST Proxy
- D. The Kafka Broker
Answer: A
Explanation:
The REST Proxy requires to receive data over REST that is already base64 encoded, hence it is the responsibility of the producer
NEW QUESTION 75
What's is true about Kafka brokers and clients from version 0.10.2 onwards?
- A. A newer client can't talk to a newer broker, but an older client can talk to a newer broker
- B. A newer client can talk to a newer broker, but an older client cannot talk to a newer broker
- C. Clients and brokers must have the exact same version to be able to communicate
- D. A newer client can talk to a newer broker, and an older client can talk to a newer broker
Answer: D
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 76
Which of the following setting increases the chance of batching for a Kafka Producer?
- A. Increase message.max.bytes
- B. Increase the number of producer threads
- C. Increase linger.ms
- D. Increase batch.size
Answer: C
Explanation:
linger.ms forces the producer to wait to send messages, hence increasing the chance of creating batches
NEW QUESTION 77
A customer has many consumer applications that process messages from a Kafka topic. Each consumer application can only process 50 MB/s. Your customer wants to achieve a target throughput of 1 GB/s. What is the minimum number of partitions will you suggest to the customer for that particular topic?
- A. 0
- B. 1
- C. 2
- D. 3
Answer: B
Explanation:
each consumer can process only 50 MB/s, so we need at least 20 consumers consuming one partition so that 50 * 20 = 1000 MB target is achieved.
NEW QUESTION 78
There are 3 producers writing to a topic with 5 partitions. There are 5 consumers consuming from the topic. How many Controllers will be present in the cluster?
- A. 0
- B. 1
- C. 2
- D. 3
Answer: B
Explanation:
There is only one controller in a cluster at all times.
NEW QUESTION 79
How can you gracefully make a Kafka consumer to stop immediately polling data from Kafka and gracefully shut down a consumer application?
- A. Call consumer.poll() in another thread
- B. Call consumer.wakeUp() and catch a WakeUpException
- C. Kill the consumer thread
Answer: B
Explanation:
See https://stackoverflow.com/a/37748336/3019499
NEW QUESTION 80
A consumer application is using KafkaAvroDeserializer to deserialize Avro messages. What happens if message schema is not present in AvroDeserializer local cache?
- A. Fetches schema from Schema Registry
- B. Throws DeserializationException
- C. Throws SerializationException
- D. Fails silently
Answer: A
Explanation:
First local cache is checked for the message schema. In case of cache miss, schema is pulled from the schema registry. An exception will be thrown in the Schema Registry does not have the schema (which should never happen if you set it up properly)
NEW QUESTION 81
Suppose you have 6 brokers and you decide to create a topic with 10 partitions and a replication factor of 3. The brokers 0 and 1 are on rack A, the brokers 2 and 3 are on rack B, and the brokers 4 and 5 are on rack C.
If the leader for partition 0 is on broker 4, and the first replica is on broker 2, which broker can host the last replica? (select two)
- A. 0
- B. 1
- C. 2
- D. 3
- E. 4
- F. 5
Answer: B,D
Explanation:
When you create a new topic, partitions replicas are spreads across racks to maintain availability. Hence, the Rack A, which currently does not hold the topic partition, will be selected for the last replica
NEW QUESTION 82
A topic receives all the orders for the products that are available on a commerce site. Two applications want to process all the messages independently - order fulfilment and monitoring. The topic has 4 partitions, how would you organise the consumers for optimal performance and resource usage?
- A. Create two consumer groups for two applications with 4 consumers in each
- B. Create 8 consumers in the same group with 4 consumers for each application
- C. Create four consumers in the same group, one for each partition - two for fulfilment and two for monitoring
- D. Create two consumers groups for two applications with 8 consumers in each
Answer: A
Explanation:
two partitions groups - one for each application so that all messages are delivered to both the application. 4 consumers in each as there are 4 partitions of the topic, and you cannot have more consumers per groups than the number of partitions (otherwise they will be inactive and wasting resources)
NEW QUESTION 83
A producer is sending messages with null key to a topic with 6 partitions using the DefaultPartitioner. Where will the messages be stored?
- A. Partition 5
- B. Any of the topic partitions
- C. Partition 0
- D. The partition for the null key
Answer: A
Explanation:
Message with no keys will be stored with round-robin strategy among partitions.
NEW QUESTION 84
Which of these joins does not require input topics to be sharing the same number of partitions?
- A. KStream-KTable join
- B. KStream-KStream join
- C. KStream-GlobalKTable
- D. KTable-KTable join
Answer: C
Explanation:
GlobalKTables have their datasets replicated on each Kafka Streams instance and therefore no repartitioning is required
NEW QUESTION 85
Consumer failed to process record # 10 and succeeded in processing record # 11. Select the course of action that you should choose to guarantee at least once processing
- A. Do not commit until successfully processing the record #10
- B. Commit offsets at 10
- C. Commit offsets at 11
Answer: C
Explanation:
Here, you shouldn't commit offsets 11 or 10 as it would indicate that the message #10 has been processed successfully.
NEW QUESTION 86
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 minutes
- B. 168 ms
- C. Broker will not start due to bad configuration
- D. 168 hours
Answer: B
Explanation:
If more than one similar config is specified, the smaller unit size will take precedence.
NEW QUESTION 87
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 the indicated producer settings num.partitions and default.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 1 partition and 1 replication factor
Answer: C
Explanation:
The broker settings comes into play when a topic is auto created
NEW QUESTION 88
......
CCDAK Premium Files Practice Valid Exam Dumps Question: https://www.examsreviews.com/CCDAK-pass4sure-exam-review.html
Get 100% Real CCDAK Accurate & Verified Answers As Seen in the Real Exam!: https://drive.google.com/open?id=1leCpCwBoB8Ye2hC-E94G8L6nbjiZZRbZ