CCDAK Exam Questions

A producer just sent a message to the leader broker for a topic partition. The producer used acks=1 and therefore the data has not yet been replicated to followers. Under which con...

Which Kafka CLI should you use to consume from a topic?

The Controller is a broker that is... (select two)

What kind of delivery guarantee this consumer offers? while (true) { ConsumerRecords<String, String> records = consumer.poll(100); try { consumer.commitSync(); } catch (CommitFaile...

What Java library is KSQL based on?

A producer application was sending messages to a partition with a replication factor of 2 by connecting to Broker 1 that was hosting partition leader. If the Broker 1 goes down, wh...

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

To prevent network-induced duplicates when producing to Kafka, I should use

Once sent to a topic, a message can be modified

A consumer wants to read messages from partitions 0 and 1 of a topic topic1. Code snippet is shown below. consumer.subscribe(Arrays.asList("topic1")); List<TopicPartition> pc = new...

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

The rule "same key goes to the same partition" is true unless...

What is returned by a producer.send() call in the Java API?

When auto.create.topics.enable is set to true in Kafka configuration, what are the circumstances under which a Kafka broker automatically creates a topic? (select three)

You are building a consumer application that processes events from a Kafka topic. What is the most important metric to monitor to ensure real-time processing?

What is not a valid authentication mechanism in Kafka?

To produce data to a topic, a producer must provide the Kafka client with...

What is the disadvantage of request/response communication?

Which of these joins does not require input topics to be sharing the same number of partitions?

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

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=1 can't produce?

Suppose you have 6 brokers and you decide to create a topic with 10 partitions and a replication factor of 3. The brokers 0 and 1 are on rack A, the brokers 2 and 3 are on rack B,...

What happens if you write the following code in your producer? producer.send(producerRecord).get()

If I supply the setting compression.type=snappy to my producer, what will happen? (select two)

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

How much should be the heap size of a broker in a production setup on a machine with 256 GB of RAM, in PLAINTEXT mode?

You have a consumer group of 12 consumers and when a consumer gets killed by the process management system, rather abruptly, it does not trigger a graceful shutdown of your consume...

What is the protocol used by Kafka clients to securely connect to the Confluent REST Proxy?

You are receiving orders from different customer in an "orders" topic with multiple partitions. Each message has the customer name as the key. There is a special customer named ABC...

In Avro, removing or adding a field that has a default is a __ schema evolution

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 produce request with acks=all is sent to broker...

Your manager would like to have topic availability over consistency. Which setting do you need to change in order to enable that?

Your streams application is reading from an input topic that has 5 partitions. You run 5 instances of your application, each with num.streams.threads set to 5. How many stream task...

How do you create a topic named test with 3 partitions and 3 replicas using the Kafka CLI?

An ecommerce wesbite sells some custom made goods. What's the natural way of modeling this data in Kafka streams?

Which of the following is not an Avro primitive type?

What is a generic unique id that I can use for messages I receive from a consumer?

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

What's a Kafka partition made of?

You are using JDBC source connector to copy data from a table to Kafka topic. There is one connector created with max.tasks equal to 2 deployed on a cluster of 3 workers. How many...

If you enable an SSL endpoint in Kafka, what feature of Kafka will be lost?

By default, which replica will be elected as a partition leader? (select two)

Partition leader election is done by

Consumer failed to process record # 10 and succeeded in processing record # 11. Select the course of action that you should choose to guarantee at least once processing

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?

Which of the following statements are true regarding the number of partitions of a topic?

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

There are 3 brokers in the cluster. You want to create a topic with a single partition that is resilient to one broker failure and one broker maintenance. What is the replication f...

Where are KSQL-related data and metadata stored?

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