Describe the Apache Kafka Queueing System and Architecture DATA-ENGINEERING-OPTIMIZE Practice Questions (Page 5)

Questions 21–21

1. 21application · medium

   A logistics company uses Kafka to process GPS location updates from delivery vehicles. Each vehicle sends its location every 5 seconds. The backend analytics team wants to process all location data for a specific vehicle in the exact order it was generated. The data is currently published to a single topic. What should the company configure to ensure ordered processing per vehicle while still allowing parallel processing across vehicles?

   • ASet the producer's acks to 'all' and enable idempotence to ensure messages are not reordered.
   • BUse the vehicle ID as the message key so all messages for a vehicle go to the same partition.
   • CCreate a separate topic for each vehicle and have each consumer subscribe to all topics.
   • DIncrease the number of partitions for the topic to improve parallelism and rely on the broker to maintain global order.
   Reveal Solution Discussion Select an answer first