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?

A. Set key.converter, value.converter to JsonConverter and the schema registry url

B. Use Single Message Transforms to add schema and payload fields in the message

C. Set key.converter.schemas.enable and value.converter.schemas.enable to false

D. Set key.converter, value.converter to AvroConverter and the schema registry url

A Zookeeper ensemble contains 3 servers. Over which ports the members of the ensemble should be able to communicate in default configuration? (select three)

A. 2181

B. 3888

C. 443

D. 2888

E. 9092

F. 80

Which Kafka CLI should you use to consume from a topic?

A. kafka-console-consumer

B. kafka-topics

C. kafka-console

D. kafka-consumer-groups

How will you find out all the partitions without a leader?

A. kafka-topics.sh --broker-list localhost:9092 --describe --under-replicated-partitions

B. kafka-topics.sh --bootstrap-server localhost:2181 --describe --unavailable-partitions

C. kafka-topics.sh --zookeeper localhost:2181 --describe --unavailable-partitions

D. kafka-topics.sh --zookeeper localhost:2181 --describe --under-replicated-partitions

How do Kafka brokers ensure great performance between the producers and consumers? (select two)

A. It compresses the messages as it writes to the disk

B. It leverages zero-copy optimisations to send data straight from the page-cache

C. It buffers the messages on disk, and sends messages from the disk reads

D. It transforms the messages into a binary format

E. It does not transform the messages

Once sent to a topic, a message can be modified

A. No

B. Yes

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

Select the Kafka Streams joins that are always windowed joins.

A. KStream-KStream join

B. KTable-KTable join

C. KStream-GlobalKTable

D. KStream-KTable join

What is returned by a producer.send() call in the Java API?

A. Future object

B. A Boolean indicating if the call succeeded

C. Future object

D. Unit

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?

A. Data will be returned from the remaining in-sync replica

B. An empty message will be returned

C. NotEnoughReplicasException will be returned

D. A new leader for the partition will be elected