Free CCDAK Exam Braindumps

When using plain JSON data with Connect, you see the following error messageorg.apache.kafka.connect.errors.DataExceptionJsonDeserializer with schemas.enable requires "schema" and "payload" fields and may not contain additional fields. How will you fix the error?

1. A. Set key.converter, value.converter to JsonConverter and the schema registry url
2. B. Use Single Message Transforms to add schema and payload fields in the message
3. C. Set key.converter.schemas.enable and value.converter.schemas.enable to false
4. D. Set key.converter, value.converter to AvroConverter and the schema registry url

Correct Answer: C
You will need to set the schemas.enable parameters for the converter to false for plain text with no schema.

To import data from external databases, I should use

1. A. Confluent REST Proxy
2. B. Kafka Connect Sink
3. C. Kafka Streams
4. D. Kafka Connect Source

Correct Answer: D
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.

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?

1. A. Create 8 consumers in the same group with 4 consumers for each application
2. B. Create two consumers groups for two applications with 8 consumers in each
3. C. Create two consumer groups for two applications with 4 consumers in each
4. D. Create four consumers in the same group, one for each partition - two for fulfilment and two for monitoring

Correct Answer: C
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)

A Zookeeper configuration has tickTime of 2000, initLimit of 20 and syncLimit of 5. What's the timeout value for followers to connect to Zookeeper?

1. A. 20 sec
2. B. 10 sec
3. C. 2000 ms
4. D. 40 sec

Correct Answer: D
tick time is 2000 ms, and initLimit is the config taken into account when establishing a connection to Zookeeper, so the answer is 2000 * 20 = 40000 ms = 40s

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

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

Correct Answer: C
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.