How Many Questions Of CCDAK Preparation

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

• A. Kerberos
• B. SASL
• C. HTTPS (SSL/TLS)
• D. HTTP

Answer: C

Explanation:
TLS - but it is still called SSL.

NEW QUESTION 2
There are five brokers in a cluster, a topic with 10 partitions and replication factor of 3, and a quota of producer_bytes_rate of 1 MB/sec has been specified for the client. What is the maximum throughput allowed for the client?

• A. 10 MB/s
• B. 0.33 MB/s
• C. 1 MB/s
• D. 5 MB/s

Answer: D

Explanation:
Each producer is allowed to produce @ 1MB/s to a broker. Max throughput 5 * 1MB, because we have 5 brokers.

NEW QUESTION 3
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

Answer: D

Explanation:
The Schema Registry stores all the schemas in the _schemas Kafka topic

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

• A. KSQL reads from the beginning of a topic, by default.
• B. KSQL reads from the end of a topi
• C. This cannot be changed.
• D. Use KSQL CLI to set auto.offset.reset property to earliest

Answer: C

Explanation:
Consumers can set auto.offset.reset property to earliest to start consuming from beginning. For KSQL, SET 'auto.offset.reset'='earliest';

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

• A. bin/kafka-topics.sh --create --broker-list localhost:9092 --replication-factor 3 --partitions 3--topic test
• B. bin/kafka-topics-create.sh --zookeeper localhost:9092 --replication-factor 3 --partitions 3--topic test
• C. bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 3 -- partitions 3 --topic test
• D. bin/kafka-topics.sh --create --bootstrap-server localhost:2181 --replication-factor 3 -- partitions 3 --topic test

Answer: C

Explanation:
As of Kafka 2.3, the kafka-topics.sh command can take --bootstrap-server localhost:9092 as an argument. You could also use the (now deprecated) option of --zookeeper localhost:2181.

NEW QUESTION 6
What is not a valid authentication mechanism in Kafka?

• A. SASL/GSSAPI
• B. SASL/SCRAM
• C. SAML
• D. SSL

Answer: C

Explanation:
Learn more about security herehttps://kafka.apache.org/documentation/#security

NEW QUESTION 7
What Java library is KSQL based on?

• A. Kafka Streams
• B. REST Proxy
• C. Schema Registry
• D. Kafka Connect

Answer: A

Explanation:
KSQL is based on Kafka Streams and allows you to express transformations in the SQL language that get automatically converted to a Kafka Streams program in the backend

NEW QUESTION 8
You have a Zookeeper cluster that needs to be able to withstand the loss of 2 servers and still be able to function. What size should your Zookeeper cluster have?

• A. 4
• B. 5
• C. 2
• D. 3
• E. 6

Answer: B

Explanation:
Your Zookeeper cluster needs to have an odd number of servers, and must maintain a majority of servers up to be able to vote. Therefore, a 2N+1 zookeeper cluster can survive to N zookeeper being down, so here the right answer is N=2, 2*N+1=5

NEW QUESTION 9
What is the default port that the KSQL server listens on?

• A. 9092
• B. 8088
• C. 8083
• D. 2181

Answer: B

Explanation:
Default port of KSQL server is 8088

NEW QUESTION 10
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 fin
• B. subscribe() will subscribe to the topic and assign() will assign partitions to the consumer.
• C. 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 11
We would like to be in an at-most once consuming scenario. Which offset commit strategy would you recommend?

• A. Commit the offsets on disk, after processing the data
• B. Do not commit any offsets and read from beginning
• C. Commit the offsets in Kafka, after processing the data
• D. Commit the offsets in Kafka, before processing the data

Answer: D

Explanation:
Here, we must commit the offsets right after receiving a batch from a call to .poll()

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

• A. KStream-KTable join
• B. KStream-KStream join
• C. KStream-GlobalKTable
• D. KTable-KTable join

Answer: C

Explanation:
GlobalKTables have their datasets replicated on each Kafka Streams instance and therefore no repartitioning is required

NEW QUESTION 13
If I want to have an extremely high confidence that leaders and replicas have my data, I
should use

• A. acks=all, replication factor=2, min.insync.replicas=1
• B. acks=1, replication factor=3, min.insync.replicas=2
• C. acks=all, replication factor=3, min.insync.replicas=2
• D. acks=all, replication factor=3, min.insync.replicas=1

Answer: C

Explanation:
acks=all means the leader will wait for all in-sync replicas to acknowledge the record. Also the min in-sync replica setting specifies the minimum number of replicas that need to be in- sync for the partition to remain available for writes.

NEW QUESTION 14
In Avro, adding a field to a record without default is a schema evolution

• A. forward
• B. backward
• C. full
• D. breaking

Answer: A

Explanation:
Clients with old schema will be able to read records saved with new schema.

NEW QUESTION 15
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?

• A. 3
• B. 5
• C. 2
• D. 1

Answer: D

Explanation:
There is only one controller in a cluster at all times.

NEW QUESTION 16
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 consumer enters rebalances even though it's still running. How can you improve this scenario?

• A. Increase max.poll.interval.ms to 600000
• B. Increase heartbeat.interval.ms to 600000
• C. Increase session.timeout.ms to 600000
• D. Add consumers to the consumer group and kill them right away

Answer: A

Explanation:
Here, we need to change the setting max.poll.interval.ms (default 300000) to its double in order to tell Kafka a consumer should be considered dead if the consumer only if it hasn't called the .poll() method in 10 minutes instead of 5.

NEW QUESTION 17
A client connects to a broker in the cluster and sends a fetch request for a partition in a topic. It gets an exception Not Leader For Partition Exception in the response. How does client handle this situation?

• A. Get the Broker id from Zookeeper that is hosting the leader replica and send request to it
• B. Send metadata request to the same broker for the topic and select the broker hosting the leader replica
• C. Send metadata request to Zookeeper for the topic and select the broker hosting the leader replica
• D. Send fetch request to each Broker in the cluster

Answer: B

Explanation:
In case the consumer has the wrong leader of a partition, it will issue a metadata request. The Metadata request can be handled by any node, so clients know afterwards which broker are the designated leader for the topic partitions. Produce and consume requests can only be sent to the node hosting partition leader.

NEW QUESTION 18
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?

• A. UnderReplicatedPartitions
• B. records-lag-max
• C. MessagesInPerSec
• D. BytesInPerSec

Answer: B

Explanation:
This metric shows the current lag (number of messages behind the broker)

NEW QUESTION 19
......