[Jun 28, 2025] CCDAK Questions Truly Valid For Your Confluent Exam!
CCDAK Actual Questions - Instant Download Tests Free Updated Today!
NEW QUESTION # 31
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: E,F
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 # 32
The Controller is a broker that is... (select two)
- A. elected by Zookeeper ensemble
- B. is responsible for partition leader election
- C. elected by broker majority
- D. is responsible for consumer group rebalances
Answer: A,B
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 # 33
What is returned by a producer.send() call in the Java API?
- A. A Boolean indicating if the call succeeded
- B. Future<RecordMetadata> object
- C. Unit
- D. Future<ProducerRecord> object
Answer: B
Explanation:
Seehttps://kafka.apache.org/21/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html
NEW QUESTION # 34
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: C
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 # 35
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 # 36
Which of the following Kafka Streams operators are stateful? (select all that apply)
- A. joining
- B. aggregate
- C. reduce
- D. flatmap
- E. count
- F. peek
Answer: A,B,C,E
Explanation:
Seehttps://kafka.apache.org/20/documentation/streams/developer-guide/dsl-api.html#stateful-transformations
NEW QUESTION # 37
Which partition assignment minimizes partition movements between two assignments?
- A. RangeAssignor
- B. StickyAssignor
- C. RoundRobinAssignor
- D. PartitionAssignor
Answer: B
NEW QUESTION # 38
If you enable an SSL endpoint in Kafka, what feature of Kafka will be lost?
- A. Exactly-once delivery
- B. Zero copy
- C. Cross-cluster mirroring
- D. Support for Avro format
Answer: B
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 # 39
What will happen if a producer tries to send messages to a topic that does not exist in the Kafka cluster?
- A. The messages will be sent to a topic called unnamed_topic_1.
- B. Messages will only be sent if auto topic creation is enabled.
- C. The brokers will hold the messages until a user creates a topic for the messages.
- D. The Producer "send()" call will block indefinitely.
Answer: B
NEW QUESTION # 40
A consumer receives a Kafka message that is serialized using an Avro schema. The consumer does not have cache locally mapping between the schema id and the schema.
What does the consumer do?
- A. The consumer drops do not consume the message because the mapping is not in its cache.
- B. The consumer consumes the message without the schema.
- C. The consumer retrieves the schema from the schema registry.
- D. The consumer throws an exception because it does not have the required schema.
Answer: C
NEW QUESTION # 41
Which configurations define which connector is deployed?
- A. rest. extension. classes
- B. value.converter
- C. key. converter
- D. connector.class
Answer: D
NEW QUESTION # 42
Producing with a key allows to...
- A. Ensure per-record level security
- B. Add more information to my message
- C. Influence partitioning of the producer messages
- D. Allow a Kafka Consumer to subscribe to a (topic,key) pair and only receive that data
Answer: C
Explanation:
Keys are necessary if you require strong ordering or grouping for messages that share the same key. If you require that messages with the same key are always seen in the correct order, attaching a key to messages will ensure messages with the same key always go to the same partition in a topic. Kafka guarantees order within a partition, but not across partitions in a topic, so alternatively not providing a key - which will result in round-robin distribution across partitions - will not maintain such order.
NEW QUESTION # 43
How do Kafka brokers ensure great performance between the producers and consumers? (select two)
- A. It compresses the messages as it writes to the disk
- B. It leverages zero-copy optimisations to send data straight from the page-cache
- C. It buffers the messages on disk, and sends messages from the disk reads
- D. It does not transform the messages
- E. It transforms the messages into a binary format
Answer: B,D
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 # 44
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-false
- B. auto.offset.reset=latest and enable.auto.commit=true
- C. auto.offset.reset=earliest and enable auto commit=true
- D. auto.offset.reset=eariiest and enable.auto.commit=false
Answer: B
NEW QUESTION # 45
Your manager would like to have topic availability over consistency. Which setting do you need to change in order to enable that?
- A. compression.type
- B. unclean.leader.election.enable
- C. min.insync.replicas
Answer: B
Explanation:
unclean.leader.election.enable=true allows non ISR replicas to become leader, ensuring availability but losing consistency as data loss will occur
NEW QUESTION # 46
......
Get instant access of 100% real exam questions with verified answers: https://pass4sure.testvalid.com/CCDAK-valid-exam-test.html