When you produce your data in that Kafka Topic, use message key like "productId" or "company/productId", this will garantee that each product will be produced in the same partition, and that will garantee for you the order of processing data of each product.