Question 1

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

Accepted Answer

A

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

Question 2

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 consume request is sent to broker?

Accepted Answer

A

Explanation: With this configuration, a single in-sync replica is still readable, but not writeable if the producer using acks=all

Question 3

To get acknowledgement of writes to only the leader partition, we need to use the config...

Accepted Answer

A

Explanation: Producers can set acks=1 to get acknowledgement from partition leader only.

Question 4

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?

Accepted Answer

B

Explanation: each consumer can process only 50 MB/s, so we need at least 20 consumers consuming one partition so that 50 * 20 = 1000 MB target is achieved.

Question 5

What information isn't stored inside of Zookeeper? (select two)

Accepted Answer

B

Explanation: Consumer offsets are stored in a Kafka topic __consumer_offsets, and the Schema Registry stored schemas in the _schemas topic.

Question 6

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

Accepted Answer

C

Explanation: With SSL, messages will need to be encrypted and decrypted, by being first loaded into the JVM, so you lose the zero copy optimization. See more information herehttps://twitter.com/ijuma/status/1161303431501324293?s=09

Question 7

The exactly once guarantee in the Kafka Streams is for which flow of data?

Accepted Answer

A

Explanation: Kafka Streams can only guarantee exactly once processing if you have a Kafka to Kafka topology.

Question 8

How will you set the retention for the topic named ‚Äúmy-topic‚Äù to 1 hour?

Accepted Answer

C

Explanation: retention.ms can be configured at topic level while creating topic or by altering topic. It shouldn't be set at the broker level (log.retention.ms) as this would impact all the topics in the cluster, not just the one we are interested in

Question 9

If a topic has a replication factor of 3...

Accepted Answer

D

Explanation: Replicas are spread across available brokers, and each replica = one broker. RF 3 = 3 brokers

Question 10

Your producer is producing at a very high rate and the batches are completely full each time. How can you improve the producer throughput? (select two)

Accepted Answer

A, C

Explanation: batch.size controls how many bytes of data to collect before sending messages to the Kafka broker. Set this as high as possible, without exceeding available memory. Enabling compression can also help make more compact batches and increase the throughput of your producer. Linger.ms will have no effect as the batches are already full

Question 11

What is the risk of increasing max.in.flight.requests.per.connection while also enabling retries in a producer?

Accepted Answer

B

Explanation: Some messages may require multiple retries. If there are more than 1 requests in flight, it may result in messages received out of order. Note an exception to this rule is if you enable the producer settingenable.idempotence=true which takes care of the out of ordering case on its own. Seehttps://issues.apache.org/jira/browse/KAFKA-5494

Question 12

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 tasks are launched?

Accepted Answer

C

Explanation: JDBC connector allows one task per table.

Question 13

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

Accepted Answer

B, D

Explanation: Preferred leader is a broker that was leader when topic was created. It is preferred because when partitions are first created, the leaders are balanced between brokers. Otherwise, any of the in-sync replicas (ISR) will be elected leader, as long as unclean.leader.election=false (by default)

Question 14

A consumer is configured with enable.auto.commit=false. What happens when close() is called on the consumer object?

Accepted Answer

B

Explanation: Calling close() on consumer immediately triggers a partition rebalance as the consumer will not be available anymore.

Question 15

is KSQL ANSI SQL compliant?

Accepted Answer

B

Explanation: KSQL is not ANSI SQL compliant, for now there are no defined standards on streaming SQL languages

Free CONFLUENT CCDAK Actual Exam Questions