We'll need to update the plugin server code to send event messages to Kafka with the new columns.

This requires leveraging the cache, adding the update logic, and sending the right data to Kafka.

The flow should be:

1. Event is about to be processed
2. Check the cache
3. Update Postgres and the cache if necessary
4. Produce the event to Kafka