We have a store selling shoes. What dataset is a great candidate to be modeled as a KTable in Kafka Streams?
A. Money made until now
B. The transaction stream
C. Items returned
D. Inventory contents right now
Using the Confluent Schema Registry, where are Avro schema stored?
A. In the Schema Registry embedded SQL database
B. In the Zookeeper node /schemas
C. In the message bytes themselves
D. In the _schemas topic
Select all that applies (select THREE)
A. min.insync.replicas is a producer setting
B. acks is a topic setting
C. acks is a producer setting
D. min.insync.replicas is a topic setting
E. min.insync.replicas matters regardless of the values of acks
F. min.insync.replicas only matters if acks=all
How does a consumer commit offsets in Kafka?
A. It directly sends a message to the __consumer_offsets topic
B. It interacts with the Group Coordinator broker
C. It directly commits the offsets in Zookeeper
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 tasks will be created and how many will be active?
A. 5 created, 1 active
B. 5 created, 5 active
C. 25 created, 25 active
D. 25 created, 5 active
A consumer wants to read messages from a specific partition of a topic. How can this be achieved?
A. Call subscribe(String topic, int partition) passing the topic and partition number as the arguments
B. Call assign() passing a Collection of TopicPartitions as the argument
C. Call subscribe() passing TopicPartition as the argument
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?
A. 0
B. 3
C. 1
D. 2
Which of the following event processing application is stateless? (select two)
A. Read events from a stream and modifies them from JSON to Avro
B. Publish the top 10 stocks each day
C. Read log messages from a stream and writes ERROR events into a high-priority stream and the rest of the events into a low-priority stream
D. Find the minimum and maximum stock prices for each day of trading
Which Kafka CLI should you use to consume from a topic?
A. kafka-console-consumer
B. kafka-topics
C. kafka-console
D. kafka-consumer-groups
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 throughput of 1 GB/s. What is the minimum number of partitions will you suggest to the customer for that particular topic?
A. 10
B. 20
C. 1
D. 50
Nowadays, the certification exams become more and more important and required by more and more enterprises when applying for a job. But how to prepare for the exam effectively? How to prepare for the exam in a short time with less efforts? How to get a ideal result and how to find the most reliable resources? Here on Vcedump.com, you will find all the answers. Vcedump.com provide not only Confluent exam questions, answers and explanations but also complete assistance on your exam preparation and certification application. If you are confused on your CCDAK exam preparations and Confluent certification application, do not hesitate to visit our Vcedump.com to find your solutions here.