You are using JDBC source connector to copy data from 3 tables to three 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?
Correct Answer:A
here, we have three tables, but the max.tasks is 2, so that's the maximum number of tasks that will be created
Which of the following is not an Avro primitive type?
Correct Answer:D
date is a logical type
Which of the following event processing application is stateless? (select two)
Correct Answer:AC
Stateless means processing of each message depends only on the message, so converting from JSON to Avro or filtering a stream are both stateless operations
What data format isn't natively available with the Confluent REST Proxy?
Correct Answer:C
Protocol buffers isn't a natively supported type for the Confluent REST Proxy, but you may use the binary format instead
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)
Correct Answer:AC
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