I'd like to be able to guarantee order per vehicle by setting the partitioning strategy to hash instead of the default strategy (least bytes), which would guarantee that all messages for the same vehicle go to the same partition. This seems relatively easy to do as Kafka has a built in balancer option that hashes by the message key, which appears to be already set to the vehicle vin.
I'd like to be able to guarantee order per vehicle by setting the partitioning strategy to hash instead of the default strategy (least bytes), which would guarantee that all messages for the same vehicle go to the same partition. This seems relatively easy to do as Kafka has a built in balancer option that hashes by the message key, which appears to be already set to the vehicle vin.