In the Kafka consumer metrics it is observed that fetch-rate is very high and each fetch is small. What steps will you take to increase throughput?

• A.Increase fetch.max.wait
• B.Increase fetch.max.bytes
• C.Decrease fetch.max.bytes
• D.Decrease fetch.min.bytes
• E.Increase fetch.min.bytes

Comment: *

Name: *

Email: *

Verification: *

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 produce request with acks=all is sent to broker?

• A.NotEnoughReplicasException will be returned
• B.Produce request is honored with single in-sync replica
• C.Produce request will block till one of the two unavailable partition is available again.

Comment: *

Name: *

Email: *

Verification: *

There are 3 producers writing to a topic with 5 partitions. There are 5 consumers consuming from the topic. How many Controllers will be present in the cluster?

• A.3
• B.5
• C.2
• D.1

Comment: *

Name: *

Email: *

Verification: *

Which of the following Kafka Streams operators are stateful? (select all that apply)

• A.flatmap
• B.reduce
• C.joining
• D.count
• E.peek
• F.aggregate

Comment: *

Name: *

Email: *

Verification: *

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

Comment: *

Name: *

Email: *

Verification: *