Go to CCDAK Questions - Try CCDAK dumps pdf
Dumps Practice Exam Questions Study Guide for the CCDAK Exam
NEW QUESTION 57
A kafka topic has a replication factor of 3 and min.insync.replicas setting of 1. What is the maximum number of brokers that can be down so that a producer with acks=all can still produce to the topic?
- A. 0
- B. 1
- C. 2
- D. 3
Answer: A
Explanation:
Two brokers can go down, and one replica will still be able to receive and serve data
NEW QUESTION 58
When using plain JSON data with Connect, you see the following error messageorg.apache.kafka.connect.errors.DataExceptionJsonDeserializer with schemas.enable requires "schema" and "payload" fields and may not contain additional fields. How will you fix the error?
- A. Set key.converter.schemas.enable and value.converter.schemas.enable to false
- B. Set key.converter, value.converter to AvroConverter and the schema registry url
- C. Set key.converter, value.converter to JsonConverter and the schema registry url
- D. Use Single Message Transforms to add schema and payload fields in the message
Answer: A
Explanation:
You will need to set the schemas.enable parameters for the converter to false for plain text with no schema.
NEW QUESTION 59
What isn't an internal Kafka Connect topic?
- A. connect-offsets
- B. connect-jars
- C. connect-configs
- D. connect-status
Answer: B
Explanation:
connect-configs stores configurations, connect-status helps to elect leaders for connect, and connect-offsets store source offsets for source connectors
NEW QUESTION 60
while (true) {
ConsumerRecords<String, String> records = consumer.poll(100);
try {
consumer.commitSync();
} catch (CommitFailedException e) {
log.error("commit failed", e)
}
for (ConsumerRecord<String, String> record records)
{
System.out.printf("topic = %s, partition = %s, offset =
%d, customer = %s, country = %s
",
record.topic(), record.partition(),
record.offset(), record.key(), record.value());
}
}
What kind of delivery guarantee this consumer offers?
- A. At-least-once
- B. Exactly-once
- C. At-most-once
Answer: C
Explanation:
Here offset is committed before processing the message. If consumer crashes before processing the message, message will be lost when it comes back up.
NEW QUESTION 61
You are using JDBC source connector to copy data from 2 tables to two Kafka topics. There is one connector created with max.tasks equal to 2 deployed on a cluster of 3 workers. How many tasks are launched?
- A. 0
- B. 1
- C. 2
- D. 3
Answer: B
Explanation:
we have two tables, so the max number of tasks is 2
NEW QUESTION 62
In Avro, adding an element to an enum without a default is a __ schema evolution
- A. forward
- B. full
- C. backward
- D. breaking
Answer: D
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 63
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. 10 MB/s
- C. 5 MB/s
- D. 1 MB/s
Answer: C
Explanation:
Each producer is allowed to produce @ 1MB/s to a broker. Max throughput 5 * 1MB, because we have 5 brokers.
NEW QUESTION 64
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. Clients and brokers must have the exact same version to be able to communicate
- C. A newer client can talk to a newer broker, and an older client can talk to a newer broker
- D. A newer client can talk to a newer broker, but an older client cannot talk to a newer broker
Answer: C
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 65
When using the Confluent Kafka Distribution, where does the schema registry reside?
- A. As a separate JVM component
- B. As an in-memory plugin on your Kafka Connect Workers
- C. As an in-memory plugin on your Kafka Brokers
- D. As an in-memory plugin on your Zookeeper cluster
Answer: A
Explanation:
Schema registry is a separate application that provides RESTful interface for storing and retrieving Avro schemas.
NEW QUESTION 66
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. KSQL reads from the beginning of a topic, by default.
- C. Use KSQL CLI to set auto.offset.reset property to earliest
Answer: C
Explanation:
Consumers can set auto.offset.reset property to earliest to start consuming from beginning. For KSQL, SET 'auto.offset.reset'='earliest';
NEW QUESTION 67
In Kafka Streams, by what value are internal topics prefixed by?
- A. group.id
- B. application.id
- C. kafka-streams-
- D. tasks-<number>
Answer: B
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 68
A Kafka producer application wants to send log messages to a topic that does not include any key. What are the properties that are mandatory to configure for the producer configuration? (select three)
- A. partition
- B. value.serializer
- C. bootstrap.servers
- D. value
- E. key.serializer
- F. key
Answer: B,C,E
Explanation:
Both key and value serializer are mandatory.
NEW QUESTION 69
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. Hopping window
- D. Sliding window
Answer: C
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 70
A bank uses a Kafka cluster for credit card payments. What should be the value of the property unclean.leader.election.enable?
- A. TRUE
- B. FALSE
Answer: B
Explanation:
Setting unclean.leader.election.enable to true means we allow out-of-sync replicas to become leaders, we will lose messages when this occurs, effectively losing credit card payments and making our customers very angry.
NEW QUESTION 71
Which of the following setting increases the chance of batching for a Kafka Producer?
- A. Increase batch.size
- B. Increase message.max.bytes
- C. Increase linger.ms
- D. Increase the number of producer threads
Answer: C
Explanation:
linger.ms forces the producer to wait to send messages, hence increasing the chance of creating batches
NEW QUESTION 72
StreamsBuilder builder = new StreamsBuilder();
KStream<String, String> textLines = builder.stream("word-count-input"); KTable<String, Long> wordCounts = textLines
.mapValues(textLine -> textLine.toLowerCase())
.flatMapValues(textLine -> Arrays.asList(textLine.split("\W+")))
.selectKey((key, word) -> word)
.groupByKey()
.count(Materialized.as("Counts"));
wordCounts.toStream().to("word-count-output", Produced.with(Serdes.String(), Serdes.Long())); builder.build(); What is an adequate topic configuration for the topic word-count-output?
- A. cleanup.policy=delete
- B. cleanup.policy=compact
- C. compression.type=lz4
- D. max.message.bytes=10000000
Answer: B
Explanation:
Result is aggregated into a table with key as the unique word and value its frequency. We have to enable log compaction for this topic to align the topic's cleanup policy with KTable semantics.
NEW QUESTION 73
What is the protocol used by Kafka clients to securely connect to the Confluent REST Proxy?
- A. Kerberos
- B. HTTPS (SSL/TLS)
- C. SASL
- D. HTTP
Answer: B
Explanation:
TLS - but it is still called SSL.
NEW QUESTION 74
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. UnderReplicatedPartitions
- C. MessagesInPerSec
- D. records-lag-max
Answer: D
Explanation:
This metric shows the current lag (number of messages behind the broker)
NEW QUESTION 75
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 will block till one of the two unavailable partition is available again.
- B. NotEnoughReplicasException will be returned
- C. Produce request is honored with single in-sync replica
Answer: B
Explanation:
With this configuration, a single in-sync replica becomes read-only. Produce request will receive NotEnoughReplicasException.
NEW QUESTION 76
A consumer wants to read messages from a specific partition of a topic. How can this be achieved?
- A. Call subscribe(String topic, int partition) passing the topic and partition number as the arguments
- B. Call subscribe() passing TopicPartition as the argument
- C. Call assign() passing a Collection of TopicPartitions as the argument
Answer: C
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 77
How often is log compaction evaluated?
- A. Every time a message is flushed to disk
- B. Every time a segment is closed
- C. Every time a message is sent to Kafka
- D. Every time a new partition is created
Answer: B
Explanation:
Log compaction is evaluated every time a segment is closed. It will be triggered if enough data is "dirty" (see dirty ratio config)
NEW QUESTION 78
How much should be the heap size of a broker in a production setup on a machine with 256 GB of RAM, in PLAINTEXT mode?
- A. 512 MB
- B. 4 GB
- C. 16 GB
- D. 128 GB
Answer: B
Explanation:
In Kafka, a small heap size is needed, while the rest of the RAM goes automatically to the page cache (managed by the OS). The heap size goes slightly up if you need to enable SSL
NEW QUESTION 79
......
Free Confluent Certified Developer CCDAK Exam Question: https://www.examtorrent.com/CCDAK-valid-vce-dumps.html
CCDAK Dumps with Practice Exam Questions Answers: https://drive.google.com/open?id=1t9GlgALBfOqOy-sfyIUbTpzrzELgGe91
