I am using the kafka intetgration as demonstrated here. Unfortunately, the kafka integration does not utilize the Key
field when sending state changes to kafka. Because the key is not utilized, it is not possible to use the compact strategy in kafka, nor is there any guarantee about order of events.
I would like the entity_id
to be sent as the Key
. Potentially this could be configurable, but I can’t think of any other field that would be 1) always available or 2) more useful.
By setting the key, the consumer could choose to use the compact strategy for retention policy and they would have some guarantees about message order.