A client connects to a broker in the cluster and sends a fetch request for a partition in a topic. It gets an exception Not Leader For Partition Exception in the response. How does client handle this situation?
Answer(s): B
In case the consumer has the wrong leader of a partition, it will issue a metadata request. The Metadata request can be handled by any node, so clients know afterwards which broker are the designated leader for the topic partitions. Produce and consume requests can only be sent to the node hosting partition leader.
What is the risk of increasing max.in.flight.requests.per.connection while also enabling retries in a producer?
Some messages may require multiple retries. If there are more than 1 requests in flight, it may result in messages received out of order. Note an exception to this rule is if you enable the producer settingenable.idempotence=true which takes care of the out of ordering case on its own.
https://issues.apache.org/jira/browse/KAFKA-5494
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)
Answer(s): A,C,D
Both key and value serializer are mandatory.
To import data from external databases, I should use
Answer(s): D
Kafka Connect Sink is used to export data from Kafka to external databases and Kafka Connect Source is used to import from external databases into Kafka.
You are running a Kafka Streams application in a Docker container managed by Kubernetes, and upon application restart, it takes a long time for the docker container to replicate the state and get back to processing the data. How can you improve dramatically the application restart?
Answer(s): A
Although any Kafka Streams application is stateless as the state is stored in Kafka, it can take a while and lots of resources to recover the state from Kafka. In order to speed up recovery, it is advised to store the Kafka Streams state on a persistent volume, so that only the missing part of the state needs to be recovered.
Post your Comments and Discuss Confluent CCDAK exam dumps with other Community members:
rurouni Commented on January 31, 2026 QUESTION: 67 We have a store selling shoes. What dataset is a great candidate to be modeled as a KTable in Kafka Streams? Correct answer: Inventory contents right now Anonymous
rurouni Commented on January 31, 2026 QUESTION: 57 A producer is sending messages with null key to a topic with 6 partitions using the DefaultPartitioner. Where will the messages be stored? Correct answer: Any of the topic partitions Anonymous
RootRanger Commented on May 05, 2025 Just went through the CCDAK practice questions. The new updates are dope, helps break down the tough parts real good. Definitely worth the time. Anonymous
Testbear Commented on June 13, 2023 please upload ITALY