Confluent Updated CCDAK Exam Questions and Answers by ozzie

The batch.size config sets the maximum number of bytes to batch per partition before sending. This allows Kafka producers to amortize I/O and improve throughput.

From Kafka Producer Configuration Docs:

“batch.size is the maximum amount of data per partition the producer will batch before sending.”

buffer.memory sets total memory for the producer, not per-batch.

send.buffer.bytes is a TCP socket buffer, not a Kafka config.

max.block.ms controls blocking time, not size.

C is true: When a new broker is added, no partitions are assigned to it unless you create new topics or reassign existing ones using kafka-reassign-partitions.sh.

D is true: Kafka brokers are hot-pluggable; no need to stop the cluster when scaling.

From Kafka Operations Guide:

“A newly added broker won’t be assigned partitions until reassignments or new topic creation.”

“Kafka allows dynamic scaling by adding brokers without downtime.”

A is false: Broker IDs must be manually set unless using dynamic broker registration in KRaft mode.

B is false unless the cluster uses KRaft mode and the broker is specifically assigned a controller role.

unclean.leader.election.enable=false → Prevents data loss by only considering in-sync replicas when rebalancing.

replication.factor → Specifies how many redundant copies of partitions are distributed across brokers.

min.insync.replicas=2 → Sets the standard for the number of partition instances that must keep up with the latest committed message.

unclean.leader.election.enable=false ensures that only in-sync replicas can be elected as leaders. If disabled, an out-of-sync replica may become leader, potentially leading to data loss.

replication.factor defines how many brokers will maintain copies of each partition, directly impacting durability and availability.

min.insync.replicas determines how many replicas must acknowledge a write when acks=all is used, enforcing write durability.

According to the official Apache Kafka consumer semantics documentation, at-most-once delivery means that records may be lost but must never be processed more than once. To achieve this guarantee, a consumer must commit offsets before processing records. If the application crashes after committing but before processing, messages are skipped rather than reprocessed, which satisfies at-most-once semantics.

Option B correctly implements this pattern. It disables automatic offset commits (enable.auto.commit=false) and explicitly calls commitAsync() immediately after polling and before processing records. This ensures that offsets are advanced regardless of whether processing succeeds, eliminating the possibility of duplicate processing.

Option C represents at-least-once semantics, because offsets are committed after processing, which can lead to duplicates on failure. Options A and D rely on automatic commits or incorrect ordering and do not provide strict at-most-once guarantees.

The Kafka documentation explicitly states that manual offset management with commits before processing is required for at-most-once delivery.

Therefore, Option B is the best and officially documented configuration and code skeleton to avoid duplicate message processing.