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

Comment: *

Name: *

Email: *

Verification: *

Which of the following statements are true regarding the number of partitions of a topic?

• A.The number of partitions in a topic cannot be altered
• B.We can add partitions in a topic by adding a broker to the cluster
• C.We can add partitions in a topic using the kafka-topics.sh command
• D.We can remove partitions in a topic by removing a broker
• E.We can remove partitions in a topic using the kafka-topics.sh command

Comment: *

Name: *

Email: *

Verification: *

A kafka topic has a replication factor of 3 and min.insync.replicas setting of 1. What is the maximum number of brokers that can be down so that a producer with acks=all can still produce to the topic?

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

Comment: *

Name: *

Email: *

Verification: *

What exceptions may be caught by the following producer? (select two)
ProducerRecord<String, String> record =
new ProducerRecord<>("topic1", "key1", "value1");
try {
producer.send(record);
} catch (Exception e) {
e.printStackTrace();
}

• A.BrokerNotAvailableException
• B.SerializationException
• C.InvalidPartitionsException
• D.BufferExhaustedException

Comment: *

Name: *

Email: *

Verification: *

If I want to send binary data through the REST proxy to topic "test_binary", it needs to be base64 encoded. A consumer connecting directly into the Kafka topic

• A."test_binary" will receive
• B.binary data
• C.avro data
• D.json data
• E.base64 encoded data, it will need to decode it

Comment: *

Name: *

Email: *

Verification: *