Question 1
What is not a valid authentication mechanism in Kafka?
Correct Answer:
C. SAML
Explanation:
Learn more about security herehttps://kafka.apache.org/documentation/#security
Free Confluent Certified Developer for Apache Kafka CCDAK Exam Questions
Question 2
You want to perform table lookups against a KTable everytime a new record is received from the KStream. What is the output of KStream-KTable join?
Correct Answer:
D. Kstream
Explanation:
Here KStream is being processed to create another KStream.
Question 3
You are using JDBC source connector to copy data from 3 tables to three Kafka topics. There is one connector created with max.tasks equal to 2 deployed on a cluster of 3 workers. How many tasks are launched?
Correct Answer:
A. 2
Explanation:
here, we have three tables, but the max.tasks is 2, so that's the maximum number of tasks that will be created
Question 4
What isn't an internal Kafka Connect topic?
Correct Answer:
D. connect-jars
Explanation:
connect-configs stores configurations, connect-status helps to elect leaders for connect, and connect-offsets store source offsets for source connectors
Question 5
Two consumers share the same group.id (consumer group id). Each consumer will
Correct Answer:
B. Read all the data on mutual exclusive partitions
Explanation:
Each consumer is assigned a different partition of the topic to consume.
Question 6
A Zookeeper ensemble contains 5 servers. What is the maximum number of servers that can go missing and the ensemble still run?
Correct Answer:
C. 2
Explanation:
majority consists of 3 zk nodes for 5 nodes zk cluster, so 2 can fail
Question 7
A bank uses a Kafka cluster for credit card payments. What should be the value of the property unclean.leader.election.enable?
Correct Answer:
A. FALSE
Explanation:
Setting unclean.leader.election.enable to true means we allow out-of-sync replicas to become leaders, we will lose messages when this occurs, effectively losing credit card payments and making our customers very angry.
Question 8
StreamsBuilder builder = new StreamsBuilder();
KStream
KTable
.mapValues(textLine -> textLine.toLowerCase())
.flatMapValues(textLine -> Arrays.asList(textLine.split("\W+")))
.selectKey((key, word) -> word)
.groupByKey()
.count(Materialized.as("Counts"));
wordCounts.toStream().to("word-count-output", Produced.with(Serdes.String(), Serdes.Long()));
builder.build();
What is an adequate topic configuration for the topic word-count-output?
Correct Answer:
D. cleanup.policy=compact
Explanation:
Result is aggregated into a table with key as the unique word and value its frequency. We have to enable log compaction for this topic to align the topic's cleanup policy with KTable semantics.
Question 9
What is true about replicas ?
Correct Answer:
C. Leader replica handles all produce and consume requests
Explanation:
Replicas are passive - they don't handle produce or consume request. Produce and consume requests get sent to the node hosting partition leader.
Question 10
What exceptions may be caught by the following producer? (select two)
ProducerRecord
new ProducerRecord<>("topic1", "key1", "value1");
try {
producer.send(record);
} catch (Exception e) {
e.printStackTrace();
}
Correct Answer:
B. SerializationException; D. BufferExhaustedException
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.