Question 1
The exactly once guarantee in the Kafka Streams is for which flow of data?
Question 2
Refer to the producer code below. It features a 'Callback' class with a method called 'onCompletion()'.
In the 'on Completion*.)' method, what does the 'metadata.offset()' value represent?
producer.send(record, new MyCallback(record));
In the 'on Completion*.)' method, what does the 'metadata.offset()' value represent?
producer.send(record, new MyCallback(record));
Question 3
You are experiencing low throughput from a Java producer. You monitor the Kafka metrics and notice that the metrics for that producer show low I/O thread ratio and low I/O thread wait ratio.
What is most likely the cause of the slow producer performance?
What is most likely the cause of the slow producer performance?
Question 4
(You deploy a Kafka Streams application with five application instances.
Kafka Streams stores application metadata using internal topics.
Auto-topic creation is disabled in the Kafka cluster.
Which statement about this scenario is true?)
Kafka Streams stores application metadata using internal topics.
Auto-topic creation is disabled in the Kafka cluster.
Which statement about this scenario is true?)
Question 5
What isn't a feature of the Confluent schema registry?