Try CCDAK Exam Valid Dumps with Instant Download Free Updates
CCDAK Dumps First Attempt Guaranteed Success
The Confluent CCDAK exam is designed to test the candidate's knowledge in various areas such as Kafka architecture, deployment, Kafka configuration, message producers, message consumers, Kafka Streams, and Kafka Connect. CCDAK exam consists of 60 multiple-choice questions and must be completed within 90 minutes.
The CCDAK certification exam covers a wide range of topics related to Apache Kafka, including core Kafka concepts, Kafka cluster management, Kafka Streams, and Kafka Connect. CCDAK exam also includes hands-on exercises that require developers to demonstrate their ability to apply their knowledge of Kafka to real-world scenarios.
To prepare for the CCDAK certification exam, candidates can take advantage of various training resources provided by Confluent. Confluent offers online training courses, workshops, and practice exams to help candidates prepare for the exam. Additionally, candidates can also refer to the Kafka documentation and community resources for further learning.
NEW QUESTION # 66
There are 3 producers writing to a topic with 5 partitions. There are 10 consumers consuming from the topic as part of the same group. How many consumers will remain idle?
- A. 0
- B. 1
- C. None
- D. 2
Answer: B
Explanation:
One consumer per partition assignment will keep 5 consumers idle.
NEW QUESTION # 67
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 # 68
You have a topic t1 in a Kafka cluster. A producer running on host A can successfully write messages to t1.
Then, you move that producer code to run on host B, but it fails writing messages to t1.
What is a likely reason for that failure?
- A. Another producer started writing to t1.
- B. Kafka ACLs are not configured to allow host B's IP address.
- C. The producer is connecting to a different broker in the same cluster.
- D. Topic T1 no longer exists in the same environment as host B.
Answer: B
NEW QUESTION # 69
Which of the following setting increases the chance of batching for a Kafka Producer?
- A. Increase the number of producer threads
- B. Increase linger.ms
- C. Increase message.max.bytes
- D. Increase batch.size
Answer: B
Explanation:
linger.ms forces the producer to wait to send messages, hence increasing the chance of creating batches
NEW QUESTION # 70
What's a Kafka partition made of?
- A. One file and two indexes
- B. One file and one index
- C. One file
- D. One file and two indexes per segment
Answer: D
Explanation:
Kafka partitions are made of segments (usually each segment is 1GB), and each segment has two corresponding indexes (offset index and time index)
NEW QUESTION # 71
Your producer is producing at a very high rate and the batches are completely full each time. How can you improve the producer throughput? (select two)
- A. Decrease linger.ms
- B. Enable compression
- C. Decrease batch.size
- D. Increase batch.size
- E. Disable compression
- F. Increase linger.ms
Answer: B,D
Explanation:
batch.size controls how many bytes of data to collect before sending messages to the Kafka broker. Set this as high as possible, without exceeding available memory. Enabling compression can also help make more compact batches and increase the throughput of your producer. Linger.ms will have no effect as the batches are already full
NEW QUESTION # 72
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: C,E
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 # 73
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. Produce request is honored with single in-sync replica
- C. NotEnoughReplicasException will be returned
Answer: C
Explanation:
With this configuration, a single in-sync replica becomes read-only. Produce request will receive NotEnoughReplicasException.
NEW QUESTION # 74
If I supply the setting compression.type=snappy to my producer, what will happen? (select two)
- A. The Producers have to compress the data
- B. The Consumers have to compress the data
- C. The Kafka brokers have to compress the data
- D. The Consumers have to de-compress the data
- E. The Kafka brokers have to de-compress the data
Answer: D
Explanation:
Kafka transfers data with zero copy and no transformation. Any transformation (including compression) is the responsibility of clients.
NEW QUESTION # 75
A producer application was sending messages to a partition with a replication factor of 2 by connecting to Broker 1 that was hosting partition leader. If the Broker 1 goes down, what will happen?
- A. The producer will stop working
- B. The producer will automatically produce to the broker that has been elected leader
- C. The topic will be unavailable
Answer: B
Explanation:
Once the client connects to any broker, it is connected to the entire cluster and in case of leadership changes, the clients automatically do a Metadata Request to an available broker to find out who is the new leader for the topic. Hence the producer will automatically keep on producing to the correct Kafka Broker
NEW QUESTION # 76
A Zookeeper ensemble contains 5 servers. What is the maximum number of servers that can go missing and the ensemble still run?
- A. 0
- B. 1
- C. 2
- D. 3
Answer: C
Explanation:
majority consists of 3 zk nodes for 5 nodes zk cluster, so 2 can fail
NEW QUESTION # 77
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 # 78
Which message delivery semantic is guaranteed by Kafka Connect?
- A. At least once
- B. Exactly once
- C. At most once
Answer: A
NEW QUESTION # 79
What exceptions may be caught by the following producer? (select two)
ProducerRecord<String, String> record =
new ProducerRecord<>("topic1", "key1", "value1");
try {
producer.send(record);
} catch (Exception e) {
e.printStackTrace();
}
- A. BufferExhaustedException
- B. SerializationException
- C. BrokerNotAvailableException
- D. InvalidPartitionsException
Answer: A,B
Explanation:
These are the client side exceptions that may be encountered before message is sent to the broker, and before a future is returned by the .send() method.
NEW QUESTION # 80
How do you create a topic named test with 3 partitions and 3 replicas using the Kafka CLI?
- A. bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 3 --partitions 3 --topic test
- B. bin/kafka-topics.sh --create --bootstrap-server localhost:2181 --replication-factor 3 --partitions 3 --topic test
- C. bin/kafka-topics-create.sh --zookeeper localhost:9092 --replication-factor 3 --partitions 3 --topic test
- D. bin/kafka-topics.sh --create --broker-list localhost:9092 --replication-factor 3 --partitions 3 --topic test
Answer: A
Explanation:
As of Kafka 2.3, the kafka-topics.sh command can take --bootstrap-server localhost:9092 as an argument. You could also use the (now deprecated) option of --zookeeper localhost:2181.
NEW QUESTION # 81
In Kafka Streams, by what value are internal topics prefixed by?
- A. tasks-<number>
- B. application.id
- C. group.id
- D. kafka-streams-
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 # 82
What is not a valid authentication mechanism in Kafka?
- A. SASL/SCRAM
- B. SASL/GSSAPI
- C. SAML
- D. SSL
Answer: C
Explanation:
Learn more about security herehttps://kafka.apache.org/documentation/#security
NEW QUESTION # 83
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. Use Single Message Transforms to add schema and payload fields in the message
- C. Set key.converter, value.converter to JsonConverter and the schema registry url
- D. Set key.converter, value.converter to AvroConverter and the schema registry url
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 # 84
To enhance compression, I can increase the chances of batching by using
- A. max.message.size=10MB
- B. batch.size=65536
- C. acks=all
- D. linger.ms=20
Answer: D
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 # 85
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 # 86
A consumer application needs to use an "at most once" delivery semantic.
What is the best consumer configuration lo avoid duplicate messages being read?
- A. auto.offset.reset=latest and enable.auto.commit=true
- B. auto.offset.reset=eariiest and enable.auto.commit=false
- C. auto.offset.reset-latest and enable auto commit-false
- D. auto.offset.reset=earliest and enable auto commit=true
Answer: A
NEW QUESTION # 87
......
100% Guarantee Download CCDAK Exam Dumps PDF Q&A: https://www.testsdumps.com/CCDAK_real-exam-dumps.html
Kickstart your Career with Real Updated Questions: https://drive.google.com/open?id=1f53Fc-qrXkkxo55u-Jw6pqduvtheuPT8
