Free CCDAK Exam Braindumps

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

1. A. forward
2. B. backward
3. C. full
4. D. breaking

Correct Answer: A
Clients with old schema will be able to read records saved with new schema.

To enhance compression, I can increase the chances of batching by using

1. A. acks=all
2. B. linger.ms=20
3. C. batch.size=65536
4. D. max.message.size=10MB

Correct Answer: B
linger.ms forces the producer to wait before sending messages, hence increasing the chance of creating batches that can be heavily compressed.

You want to perform table lookups against a KTable everytime a new record is received from the KStream. What is the output of KStream-KTable join?

1. A. KTable
2. B. GlobalKTable
3. C. You choose between KStream or KTable
4. D. Kstream

Correct Answer: D
Here KStream is being processed to create another KStream.

Which of the following errors are retriable from a producer perspective? (select two)

1. A. MESSAGE_TOO_LARGE
2. B. INVALID_REQUIRED_ACKS
3. C. NOT_ENOUGH_REPLICAS
4. D. NOT_LEADER_FOR_PARTITION
5. E. TOPIC_AUTHORIZATION_FAILED

Correct Answer: CD
Both of these are retriable errors, others non-retriable errors. See the full list of errors and their "retriable" status herehttps://kafka.apache.org/protocol#protocol_error_codes

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?

1. A. 6
2. B. 1
3. C. 2
4. D. 3

Correct Answer: C
we have two tables, so the max number of tasks is 2