CONFLUENT CCDAK
Q: 1
Which Kafka CLI should you use to consume from a topic?
Options
Q: 2
Which of the following setting increases the chance of batching for a Kafka Producer?
Options
Q: 3
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)
Options
Q: 4
Where are the ACLs stored in a Kafka cluster by default?
Options
Q: 5
We want the average of all events in every five-minute window updated every minute. What kind of
Kafka Streams window will be required on the stream?
Options
Q: 6
Your topic is log compacted and you are sending a message with the key K and value null. What will
happen?
Options
Q: 7
Select all that applies (select THREE)
Options
Q: 8
When is the onCompletion() method called?
private class ProducerCallback implements Callback {
@Override
public void onCompletion(RecordMetadata recordMetadata, Exception e) {
if (e != null) {
e.printStackTrace();
}
}
}
ProducerRecord record =
new ProducerRecord("topic1", "key1", "value1");
producer.send(record, new ProducerCallback());
Options
Q: 9
What is not a valid authentication mechanism in Kafka?
Options
Q: 10
What Java library is KSQL based on?
Options
Question 1 of 10
