2022 CCDAK Dumps PDF - CCDAK Real Exam Questions Answers
Valid CCDAK Test Answers & Confluent CCDAK Exam PDF
NEW QUESTION 58
A producer is sending messages with null key to a topic with 6 partitions using the DefaultPartitioner. Where will the messages be stored?
- A. Any of the topic partitions
- B. Partition 5
- C. The partition for the null key
- D. Partition 0
Answer: B
Explanation:
Message with no keys will be stored with round-robin strategy among partitions.
NEW QUESTION 59
is KSQL ANSI SQL compliant?
- A. No
- B. Yes
Answer: A
Explanation:
KSQL is not ANSI SQL compliant, for now there are no defined standards on streaming SQL languages
NEW QUESTION 60
Two consumers share the same group.id (consumer group id). Each consumer will
- A. Read all the data on mutual exclusive partitions
- B. Read mutually exclusive offsets blocks on all the partitions
- C. Read all data from all partitions
Answer: A
Explanation:
Each consumer is assigned a different partition of the topic to consume.
NEW QUESTION 61
The exactly once guarantee in the Kafka Streams is for which flow of data?
- A. External => Kafka
- B. Kafka => Kafka
- C. Kafka => External
Answer: B
Explanation:
Kafka Streams can only guarantee exactly once processing if you have a Kafka to Kafka topology.
NEW QUESTION 62
Which is an optional field in an Avro record?
- A. doc
- B. name
- C. fields
- D. namespace
Answer: A
Explanation:
doc represents optional description of message
NEW QUESTION 63
Which of the following setting increases the chance of batching for a Kafka Producer?
- A. Increase the number of producer threads
- B. Increase linger.ms
- C. Increase batch.size
- D. Increase message.max.bytes
Answer: B
Explanation:
linger.ms forces the producer to wait to send messages, hence increasing the chance of creating batches
NEW QUESTION 64
What exceptions may be caught by the following producer? (select two)
ProducerRecord<String, String> record =
new ProducerRecord<>("topic1", "key1", "value1");
try {
producer.send(record);
} catch (Exception e) {
e.printStackTrace();
}
- A. InvalidPartitionsException
- B. SerializationException
- C. BrokerNotAvailableException
- D. BufferExhaustedException
Answer: B,D
Explanation:
These are the client side exceptions that may be encountered before message is sent to the broker, and before a future is returned by the .send() method.
NEW QUESTION 65
How can you gracefully make a Kafka consumer to stop immediately polling data from Kafka and gracefully shut down a consumer application?
- A. Call consumer.wakeUp() and catch a WakeUpException
- B. Call consumer.poll() in another thread
- C. Kill the consumer thread
Answer: A
Explanation:
See https://stackoverflow.com/a/37748336/3019499
NEW QUESTION 66
Which of the following is not an Avro primitive type?
- A. int
- B. date
- C. string
- D. null
- E. long
Answer: B
Explanation:
date is a logical type
NEW QUESTION 67
Which of the following Kafka Streams operators are stateless? (select all that apply)
- A. map
- B. aggregate
- C. branch
- D. filter
- E. flatmap
- F. groupBy
Answer: A,C,D,E,F
Explanation:
Seehttps://kafka.apache.org/20/documentation/streams/developer-guide/dsl-api.html#stateless-transformations
NEW QUESTION 68
In Avro, adding an element to an enum without a default is a __ schema evolution
- A. forward
- B. full
- C. breaking
- D. backward
Answer: C
Explanation:
Since Confluent 5.4.0, Avro 1.9.1 is used. Since default value was added to enum complex type , the schema resolution changed from:
(<1.9.1) if both are enums:** if the writer's symbol is not present in the reader's enum, then an error is signalled. **(>=1.9.1) if both are enums:
if the writer's symbol is not present in the reader's enum and the reader has a default value, then that value is used, otherwise an error is signalled.
NEW QUESTION 69
A consumer application is using KafkaAvroDeserializer to deserialize Avro messages. What happens if message schema is not present in AvroDeserializer local cache?
- A. Fails silently
- B. Throws SerializationException
- C. Fetches schema from Schema Registry
- D. Throws DeserializationException
Answer: C
Explanation:
First local cache is checked for the message schema. In case of cache miss, schema is pulled from the schema registry. An exception will be thrown in the Schema Registry does not have the schema (which should never happen if you set it up properly)
NEW QUESTION 70
How often is log compaction evaluated?
- A. Every time a message is sent to Kafka
- B. Every time a segment is closed
- C. Every time a new partition is created
- D. Every time a message is flushed to disk
Answer: B
Explanation:
Log compaction is evaluated every time a segment is closed. It will be triggered if enough data is "dirty" (see dirty ratio config)
NEW QUESTION 71
To continuously export data from Kafka into a target database, I should use
- A. Kafka Producer
- B. Kafka Streams
- C. Kafka Connect Sink
- D. Kafka Connect Source
Answer: C
Explanation:
Kafka Connect Sink is used to export data from Kafka to external databases and Kafka Connect Source is used to import from external databases into Kafka.
NEW QUESTION 72
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?
- A. Produce request is honored with single in-sync replica
- B. Produce request will block till one of the two unavailable partition is available again.
- C. NotEnoughReplicasException will be returned
Answer: C
Explanation:
With this configuration, a single in-sync replica becomes read-only. Produce request will receive NotEnoughReplicasException.
NEW QUESTION 73
The kafka-console-consumer CLI, when used with the default options
- A. always uses the same group id
- B. uses a random group id
- C. does not use a group id
Answer: B
Explanation:
If a group is not specified, the kafka-console-consumer generates a random consumer group.
NEW QUESTION 74
To transform data from a Kafka topic to another one, I should use
- A. Kafka Connect Sink
- B. Consumer + Producer
- C. Kafka Streams
- D. Kafka Connect Source
Answer: C
Explanation:
Kafka Streams is a library for building streaming applications, specifically applications that transform input Kafka topics into output Kafka topics
NEW QUESTION 75
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 ArrayList<>();
pc.add(new PartitionTopic("topic1", 0));
pc.add(new PartitionTopic("topic1", 1));
consumer.assign(pc);
- A. This works fine. subscribe() will subscribe to the topic and assign() will assign partitions to the consumer.
- B. Throws IllegalStateException
Answer: B
Explanation:
subscribe() and assign() cannot be called by the same consumer, subscribe() is used to leverage the consumer group mechanism, while assign() is used to manually control partition assignment and reads assignment
NEW QUESTION 76
Which actions will trigger partition rebalance for a consumer group? (select three)
- A. Remove a broker from the cluster
- B. A consumer in a consumer group shuts down
- C. Add a new consumer to consumer group
- D. Increase partitions of a topic
Answer: B,C,D
Explanation:
Add a broker to the cluster
Explanation:
Rebalance occurs when a new consumer is added, removed or consumer dies or paritions increased.
NEW QUESTION 77
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 many tasks are launched?
- A. 0
- B. 1
- C. 2
- D. 3
Answer: C
Explanation:
we have two tables, so the max number of tasks is 2
NEW QUESTION 78
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 monitoring. The topic has 4 partitions, how would you organise the consumers for optimal performance and resource usage?
- A. Create two consumers groups for two applications with 8 consumers in each
- B. Create four consumers in the same group, one for each partition - two for fulfilment and two for monitoring
- C. Create 8 consumers in the same group with 4 consumers for each application
- D. Create two consumer groups for two applications with 4 consumers in each
Answer: D
Explanation:
two partitions groups - one for each application so that all messages are delivered to both the application. 4 consumers in each as there are 4 partitions of the topic, and you cannot have more consumers per groups than the number of partitions (otherwise they will be inactive and wasting resources)
NEW QUESTION 79
In Java, Avro SpecificRecords classes are
- A. automatically generated from an Avro Schema + a Maven / Gradle Plugin
- B. automatically generated from an Avro Schema
- C. written manually by the programmer
Answer: A
Explanation:
SpecificRecord is created from generated record classes
NEW QUESTION 80
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)
- A. Client alters number of partitions of a topic
- B. Consumer reads message from a topic
- C. Client requests metadata for a topic
- D. Producer sends message to a topic
Answer: B,C,D
Explanation:
A kafka broker automatically creates a topic under the following circumstances- When a producer starts writing messages to the topic - When a consumer starts reading messages from the topic - When any client requests metadata for the topic
NEW QUESTION 81
In Kafka Streams, by what value are internal topics prefixed by?
- A. tasks-<number>
- B. group.id
- C. application.id
- D. kafka-streams-
Answer: C
Explanation:
In Kafka Streams, the application.id is also the underlying group.id for your consumers, and the prefix for all internal topics (repartition and state)
NEW QUESTION 82
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?
- A. The REST Proxy
- B. Zookeeper
- C. The Kafka Broker
- D. The Producer
Answer: D
Explanation:
The REST Proxy requires to receive data over REST that is already base64 encoded, hence it is the responsibility of the producer
NEW QUESTION 83
......
CCDAK Exam Dumps - PDF Questions and Testing Engine: https://www.braindumpquiz.com/CCDAK-exam-material.html
Realistic CCDAK Exam Dumps with Accurate & Updated Questions: https://drive.google.com/open?id=19JN13nAcAsUAKY5CO2-GU1KKLlpRdL5K