CCDAK Exam Questions

What exceptions may be caught by the following producer? (select two) ProducerRecord<String, String> record = new ProducerRecord<>("topic1", "key1", "value1"); try { producer.send(...

You want to send a message of size 3 MB to a topic with default message size configuration. How does KafkaProducer handle large messages?

What happens when broker.rack configuration is provided in broker configuration in Kafka cluster?

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

Two consumers share the same group.id (consumer group id). Each consumer will

How will you set the retention for the topic named my-topic to 1 hour?

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

If I want to send binary data through the REST proxy, it needs to be base64 encoded. Which component needs to encode the binary data into base 64?

What is true about replicas ?

A topic "sales" is being produced to in the Americas region. You are mirroring this topic using Mirror Maker to the European region. From there, you are only reading the topic for...

There are five brokers in a cluster, a topic with 10 partitions and replication factor of 3, and a quota of producer_bytes_rate of 1 MB/sec has been specified for the client. What...

In Avro, adding an element to an enum without a default is a __ schema evolution

A Zookeeper configuration has tickTime of 2000, initLimit of 20 and syncLimit of 5. What's the timeout value for followers to connect to Zookeeper?

To continuously export data from Kafka into a target database, I should use

In Kafka, every broker... (select three)

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

Is KSQL ANSI SQL compliant?

What information isn't stored inside of Zookeeper? (select two)

Which KSQL queries write to Kafka?

There are two consumers C1 and C2 belonging to the same group G subscribed to topics T1 and T2. Each of the topics has 3 partitions. How will the partitions be assigned to consumer...

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...

What is the risk of increasing max.in.flight.requests.per.connection while also enabling retries in a producer?

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 configura...

To import data from external databases, I should use

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 th...

What client protocol is supported for the schema registry? (select two)

If I produce to a topic that does not exist, and the broker setting auto.create.topic.enable=true, what will happen?

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?

What is an adequate topic configuration for the topic word-count-output? StreamsBuilder builder = new StreamsBuilder(); KStream<String, String> textLines = builder.stream("word-cou...

Select the Kafka Streams joins that are always windowed joins.

There are 3 producers writing to a topic with 5 partitions. There are 10 consumers consuming from the topic as part of the same group. How many consumers will remain idle?

To transform data from a Kafka topic to another one, I should use

What is true about partitions? (select two)

You have a Zookeeper cluster that needs to be able to withstand the loss of 2 servers and still be able to function. What size should your Zookeeper cluster have?

A kafka topic has a replication factor of 3 and min.insync.replicas setting of 2. How many brokers can go down before a producer with acks=all can't produce?

In the Kafka consumer metrics it is observed that fetch-rate is very high and each fetch is small. What steps will you take to increase throughput?

When using the Confluent Kafka Distribution, where does the schema registry reside?

Compaction is enabled for a topic in Kafka by setting log.cleanup.policy=compact. What is true about log compaction?

When is the onCompletion() method called? private class ProducerCallback implements Callback { @Override public void onCompletion(RecordMetadata recordMetadata, Exception e) { if (...

Using the Confluent Schema Registry, where are Avro schema stored?

Which of the following setting increases the chance of batching for a Kafka Producer?

You have a Kafka cluster and all the topics have a replication factor of 3. One intern at your company stopped a broker, and accidentally deleted all the data of that broker on the...

Select all that applies (select THREE)

A customer has many consumer applications that process messages from a Kafka topic. Each consumer application can only process 50 MB/s. Your customer wants to achieve a target thro...

Your producer is producing at a very high rate and the batches are completely full each time. How can you improve the producer throughput? (select two)

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

A consumer wants to read messages from a specific partition of a topic. How can this be achieved?

If I want to have an extremely high confidence that leaders and replicas have my data, I should use

Where are the dynamic configurations for a topic stored?

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...