CCDAK Exam Questions

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

Which is an optional field in an Avro record?

A consumer application is using KafkaAvroDeserializer to deserialize Avro messages. What happens if message schema is not present in AvroDeserializer local cache?

Which of the following event processing application is stateless? (select two)

A consumer starts and has auto.offset.reset=latest, and the topic partition currently has data for offsets going from 45 to 2311. The consumer group has committed the offset 643 fo...

A Zookeeper ensemble contains 3 servers. Over which ports the members of the ensemble should be able to communicate in default configuration? (select three)

To get acknowledgement of writes to only the leader partition, we need to use the config...

How will you find out all the partitions where one or more of the replicas for the partition are not in- sync with the leader?

If a topic has a replication factor of 3...

How do Kafka brokers ensure great performance between the producers and consumers? (select two)

What isn't an internal Kafka Connect topic?

To enhance compression, I can increase the chances of batching by using

There are 3 producers writing to a topic with 5 partitions. There are 5 consumers consuming from the topic. How many Controllers will be present in the cluster?

The exactly once guarantee in the Kafka Streams is for which flow of data?

We would like to be in an at-most once consuming scenario. Which offset commit strategy would you recommend?

A topic receives all the orders for the products that are available on a commerce site. Two applications want to process all the messages independently - order fulfilment and monit...

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

A bank uses a Kafka cluster for credit card payments. What should be the value of the property unclean.leader.election.enable?

A kafka topic has a replication factor of 3 and min.insync.replicas setting of 1. What is the maximum number of brokers that can be down so that a producer with acks=all can still...

I am producing Avro data on my Kafka cluster that is integrated with the Confluent Schema Registry. After a schema change that is incompatible, I know my data will be rejected. Whi...

How will you read all the messages from a topic in your KSQL query?

You want to sink data from a Kafka topic to S3 using Kafka Connect. There are 10 brokers in the cluster, the topic has 2 partitions with replication factor of 3. How many tasks wil...

Producing with a key allows to...

Select all the way for one consumer to subscribe simultaneously to the following topics - topic.history, topic.sports, topic.politics? (select two)

What isn't a feature of the Confluent schema registry?

Which of the following errors are retriable from a producer perspective? (select two)

How will you find out all the partitions without a leader?

Which actions will trigger partition rebalance for a consumer group? (select three)

Kafka is configured with following parameters - log.retention.hours = 168 log.retention.minutes = 168 log.retention.ms = 168 How long will the messages be retained for?

To read data from a topic, the following configuration is needed for the consumers

How does a consumer commit offsets in Kafka?

In Java, Avro SpecificRecords classes are

A producer is sending messages with null key to a topic with 6 partitions using the DefaultPartitioner. Where will the messages be stored?

A topic has three replicas and you set min.insync.replicas to 2. If two out of three replicas are not available, what happens when a consume request is sent to broker?

In Avro, removing a field that does not have a default is a __ schema evolution

An ecommerce website maintains two topics - a high volume "purchase" topic with 5 partitions and low volume "customer" topic with 3 partitions. You would like to do a stream-table...

You are sending messages with keys to a topic. To increase throughput, you decide to increase the number of partitions of the topic. Select all that apply.

In Kafka Streams, by what value are internal topics prefixed by?

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

You are doing complex calculations using a machine learning framework on records fetched from a Kafka topic. It takes more about 6 minutes to process a record batch, and the consum...

What data format isn't natively available with the Confluent REST Proxy?

The kafka-console-consumer CLI, when used with the default options

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

When using plain JSON data with Connect, you see the following error messageorg.apache.kafka.connect.errors.DataExceptionJsonDeserializer with schemas.enable requires "schema" and...

To allow consumers in a group to resume at the previously committed offset, I need to set the proper value for...

A Zookeeper ensemble contains 5 servers. What is the maximum number of servers that can go missing and the ensemble still run?

A consumer sends a request to commit offset 2000. There is a temporary communication problem, so the broker never gets the request and therefore never responds. Meanwhile, the cons...

Your topic is log compacted and you are sending a message with the key K and value null. What will happen?

How often is log compaction evaluated?

A producer application in a developer machine was able to send messages to a Kafka topic. After copying the producer application into another developer's machine, the producer is a...