Confluent Certified Developer for Apache Kafka Certification Examination Sample Questions:
1. Match the topic configuration setting with the reason the setting affects topic durability.
(You are given settings like unclean.leader.election.enable=false, replication.factor, min.insync.replicas=2)
2. Your company has three Kafka clusters: Development, Testing, and Production.
The Production cluster is running out of storage, so you add a new node.
Which two statements about the new node are true?
(Select two.)
A) A node ID will be assigned to the new node automatically.
B) A newly added node will have KRaft controller role by default.
C) A new node will not have any partitions assigned to it unless a new topic is created or reassignment occurs.
D) A new node can be added without stopping existing cluster nodes.
3. (You are implementing a Kafka Streams application to process financial transactions.
Each transaction must be processed exactly once to ensure accuracy.
The application reads from an input topic, performs computations, and writes results to an output topic.
During testing, you notice duplicate entries in the output topic, which violates the exactly-once processing requirement.
You need to ensure exactly-once semantics (EOS) for this Kafka Streams application.
Which step should you take?)
A) Set enable.idempotence=true in the internal producer configuration of the Kafka Streams application.
B) Set processing.guarantee=exactly_once_v2 in the Kafka Streams configuration.
C) Set enable.exactly_once=true in the Kafka Streams configuration.
D) Enable compaction on the output topic to handle duplicates.
4. You are writing a producer application and need to ensure proper delivery. You configure the producer with acks=all.
Which two actions should you take to ensure proper error handling?
(Select two.)
A) Use a callback argument in producer.send() where you check delivery status.
B) Surround the call of producer.send() with a try/catch block to catch KafkaException.
C) Check the value of ProducerRecord.status().
D) Check that producer.send() returned a RecordMetadata object and is not null.
5. (You are designing a stream pipeline to monitor the real-time location of GPS trackers, where historical location data is not required.
Each event has:
* Key: trackerId
* Value: latitude, longitude
You need to ensure that the latest location for each tracker is always retained in the Kafka topic.
Which topic configuration parameter should you set?)
A) min.cleanable.dirty.ratio=-1
B) retention.ms=0
C) cleanup.policy=compact
D) retention.ms=infinite
Solutions:
| Question # 1 Answer: Only visible for members | Question # 2 Answer: C,D | Question # 3 Answer: B | Question # 4 Answer: A,B | Question # 5 Answer: C |
1161 Customer Reviews
Quality and ValueITCertKing Practice Exams are written to the highest standards of technical accuracy, using only certified subject matter experts and published authors for development - no all study materials.
Tested and ApprovedWe are committed to the process of vendor and third party approvals. We believe professionals and executives alike deserve the confidence of quality coverage these authorizations provide.
Easy to PassIf you prepare for the exams using our ITCertKing testing engine, It is easy to succeed for all certifications in the first attempt. You don't have to deal with all dumps or any free torrent / rapidshare all stuff.
Try Before BuyITCertKing offers free demo of each product. You can check out the interface, question quality and usability of our practice exams before you decide to buy.
