Your streams application is reading from an input topic that has 5 partitions. You run 5 instances of your application, each with num.streams.threads set to 5. How many stream tasks will be created and how many will be active?
Correct Answer:D
One partition is assigned a thread, so only 5 will be active, and 25 threads (i.e. tasks) will be created
What isn't an internal Kafka Connect topic?
Correct Answer:D
connect-configs stores configurations, connect-status helps to elect leaders for connect, and connect-offsets store source offsets for source connectors
If I produce to a topic that does not exist, and the broker setting auto.create.topic.enable=true, what will happen?
Correct Answer:C
The broker settings comes into play when a topic is auto created
Which is an optional field in an Avro record?
Correct Answer:A
doc represents optional description of message
A producer just sent a message to the leader broker for a topic partition. The producer used acks=1 and therefore the data has not yet been replicated to followers. Under which conditions will the consumer see the message?
Correct Answer:D
The high watermark is an advanced Kafka concept, and is advanced once all the ISR replicates the latest offsets. A consumer can only read up to the value of the High Watermark (which can be less than the highest offset, in the case of acks=1)