The key in a Kafka message ensures that the messages the same key are delivered to the same Kafka partition and the order of messages arrival is maintained.  This should help host-inventory to to avoid host-duplication.

 Add "key: org_id" to Kafka messages destined for "Host-Inventory" for creating/update hosts.