CCDAK Exam Questions
216 real CCDAK exam questions with expert-verified answers and explanations. Page 2 of 5.
- Question #51
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...
- Question #52
Which Kafka CLI should you use to consume from a topic?
- Question #53
The Controller is a broker that is... (select two)
- Question #54
What kind of delivery guarantee this consumer offers? while (true) { ConsumerRecords<String, String> records = consumer.poll(100); try { consumer.commitSync(); } catch (CommitFaile...
- Question #55
What Java library is KSQL based on?
- Question #56
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...
- Question #57
How can you gracefully make a Kafka consumer to stop immediately polling data from Kafka and gracefully shut down a consumer application?
- Question #58
To prevent network-induced duplicates when producing to Kafka, I should use
- Question #59
Once sent to a topic, a message can be modified
- Question #60
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...
- Question #61
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...
- Question #62
The rule "same key goes to the same partition" is true unless...
- Question #63
What is returned by a producer.send() call in the Java API?
- Question #64
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)
- Question #65
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?
- Question #66
What is not a valid authentication mechanism in Kafka?
- Question #67
To produce data to a topic, a producer must provide the Kafka client with...
- Question #68
What is the disadvantage of request/response communication?
- Question #69
Which of these joins does not require input topics to be sharing the same number of partitions?
- Question #70
What are the requirements for a Kafka broker to connect to a Zookeeper ensemble? (select two)
- Question #71
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?
- Question #72
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,...
- Question #73
What happens if you write the following code in your producer? producer.send(producerRecord).get()
- Question #74
If I supply the setting compression.type=snappy to my producer, what will happen? (select two)
- Question #75
What is the default port that the KSQL server listens on?
- Question #76
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?
- Question #77
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...
- Question #78
What is the protocol used by Kafka clients to securely connect to the Confluent REST Proxy?
- Question #79
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...
- Question #80
In Avro, removing or adding a field that has a default is a __ schema evolution
- Question #81
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...
- Question #82
Your manager would like to have topic availability over consistency. Which setting do you need to change in order to enable that?
- Question #83
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...
- Question #84
How do you create a topic named test with 3 partitions and 3 replicas using the Kafka CLI?
- Question #85
An ecommerce wesbite sells some custom made goods. What's the natural way of modeling this data in Kafka streams?
- Question #86
Which of the following is not an Avro primitive type?
- Question #87
What is a generic unique id that I can use for messages I receive from a consumer?
- Question #88
Which of the following Kafka Streams operators are stateless? (select all that apply)
- Question #89
What's a Kafka partition made of?
- Question #90
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...
- Question #91
If you enable an SSL endpoint in Kafka, what feature of Kafka will be lost?
- Question #92
By default, which replica will be elected as a partition leader? (select two)
- Question #93
Partition leader election is done by
- Question #94
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
- Question #95
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?
- Question #96
Which of the following statements are true regarding the number of partitions of a topic?
- Question #97
Which of the following is true regarding thread safety in the Java Kafka Clients?
- Question #98
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...
- Question #99
Where are KSQL-related data and metadata stored?
- Question #100
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...