In Kafka, every broker... (select three)

• A.contains all the topics and all the partitions
• B.knows all the metadata for all topics and partitions
• C.is a controller
• D.knows the metadata for the topics and partitions it has on its disk
• E.is a bootstrap broker
• F.contains only a subset of the topics and the partitions

Comment: *

Name: *

Email: *

Verification: *

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

• A.map
• B.filter
• C.flatmap
• D.branch
• E.groupBy
• F.aggregate

Comment: *

Name: *

Email: *

Verification: *

Kafka is configured with following parameters - log.retention.hours = 168 log.retention.minutes = 168 log.retention.ms = 168 How long will the messages be retained for?

• A.Broker will not start due to bad configuration
• B.168 ms
• C.168 hours
• D.168 minutes

Comment: *

Name: *

Email: *

Verification: *

You are sending messages with keys to a topic. To increase throughput, you decide to increase the number of partitions of the topic. Select all that apply.

• A.All the existing records will get rebalanced among the partitions to balance load
• B.New records with the same key will get written to the partition where old records with that key were written
• C.New records may get written to a different partition
• D.Old records will stay in their partitions

Comment: *

Name: *

Email: *

Verification: *

In Avro, adding a field to a record without default is a __ schema evolution

• A.forward
• B.backward
• C.full
• D.breaking

Comment: *

Name: *

Email: *

Verification: *