NEW QUESTION 22
What are two examples of performance metrics?
(Select two.)

NEW QUESTION 23
(You are developing a Java application that includes a Kafka consumer.
You need to integrate Kafka client logs with your own application logs.
Your application is using the Log4j2 logging framework.
Which Java library dependency must you include in your project?)

NEW QUESTION 24
To prevent network-induced duplicates when producing to Kafka, I should use

NEW QUESTION 25
When running a ksqlDB for connectors, what does the IF NOT EXISTS clause do?

NEW QUESTION 26
An application is consuming messages from Kafka.
The application logs show that partitions are frequently being reassigned within the consumer group.
Which two factors may be contributing to this?
(Select two.)

NEW QUESTION 27
What is true about replicas ?

NEW QUESTION 28
Which partition assignment minimizes partition movements between two assignments?

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

NEW QUESTION 30
Match the testing tool with the type of test it is typically used to perform.

NEW QUESTION 31
You need to consume messages from Kafka using the command-line interface (CLI).
Which command should you use?

NEW QUESTION 32
Partition leader election is done by

NEW QUESTION 33
You are creating a Kafka Streams application to process retail data.
Match the input data streams with the appropriate Kafka Streams object.

NEW QUESTION 34
You have a Kafka consumer in production actively reading from a critical topic.
You need to update the offset of your consumer to start reading from the beginning of the topic.
Which action should you take?

NEW QUESTION 35
Which configuration determines how many bytes of data are collected before sending messages to the Kafka broker?

NEW QUESTION 36
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));

NEW QUESTION 37
Your application is consuming from a topic configured with a deserializer.
It needs to be resilient to badly formatted records (“poison pills”). You surround the poll() call with a try/catch for RecordDeserializationException.
You need to log the bad record, skip it, and continue processing.
Which action should you take in the catch block?