DRAG DROP -

Match the topic configuration setting with the reason the setting affects topic durability.

To answer, move each of the options below to the corresponding answer area. Partial credit is given for each correct answer.

You are designing a stream pipeline to monitor the real-time location of GPS trackers, where historical location data is not required.

Each event in the stream has the following structure:

• Key: tracker_id
• Value: latitude, longitude

You need to ensure that the latest location for each tracker is always retained in the Kafka topic.

Which topic configuration parameter should you set?

You need to collect logs from a host and write them to a Kafka topic named 'logs-topic'. You decide to use Kafka Connect File Source connector for this task.

What is the preferred deployment mode for this connector?

You create a topic named 'IoT-Data' with 10 partitions and replication factor of three. A producer application is producing messages with 1 mb size. The messages need to be compressed using Gzip compression.

Which two statements are true in this scenario? (Choose two.)

The producer code below features a 'Callback' class with a method called 'onCompletion()'.

When will the 'onCompletion()' method be invoked?