CCDAK Practice Exam Questions with Answers Confluent Certified Developer for Apache Kafka Certification Examination Certification

You are using JDBC source connector to copy data from 2 tables to two 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?

Where are the ACLs stored in a Kafka cluster by default?

If I want to send binary data through the REST proxy to topic "test_binary", it needs to be base64 encoded. A consumer connecting directly into the Kafka topic A. "test_binary" will receive

B. binary data

C. avro data

D. json data

E. base64 encoded data, it will need to decode it

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());

What is the default port that the KSQL server listens on?

What are the requirements for a Kafka broker to connect to a Zookeeper ensemble? (select two)

What's a Kafka partition made of?

How can you gracefully make a Kafka consumer to stop immediately polling data from Kafka and gracefully shut down a consumer application?

In Avro, adding a field to a record without default is a __ schema evolution

Where are KSQL-related data and metadata stored?

A consumer is configured with enable.auto.commit=false. What happens when close() is called on the consumer object?

We have a store selling shoes. What dataset is a great candidate to be modeled as a KTable in Kafka Streams?

What's is true about Kafka brokers and clients from version 0.10.2 onwards?

Which of the following Kafka Streams operators are stateful? (select all that apply)

How does a consumer commit offsets in Kafka?

is KSQL ANSI SQL compliant?

Which of the following is true regarding thread safety in the Java Kafka Clients?