CCDAK

Question 6

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.

Question 7

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?

1. retention.ms = 0
2. min.cleanable.dirty.ratio = -1
3. cleanup.policy = compact
4. retention.ms = infinite

Question 8

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?

1. Standalone mode
2. Distributed mode
3. Parallel mode
4. SingleCluster mode

Question 9

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.)

1. Compression type will be stored in batch attributes.
2. By default, compression is the producer's responsibility.
3. The message is already compressed so it will not be serialized.
4. All compressed messages will be stored in the same topic partition.

Question 10

The producer code below features a 'Callback' class with a method called 'onCompletion()'. When will the 'onCompletion()' method be invoked?

1. When a consumer sends an acknowledgement to the producer
2. When the producer puts the message into its socket buffer
3. When the producer batches the message
4. When the producer receives the acknowledgment from the broker