the idea is to decouple here.

In the Endpoint, we write the payload to the topic:

new ProducerRecord(topic, key, payload)

where the key could/would be the push-message-id and the value the variant, or just it's ID.

the idea on the consumer is to actually perform the call to the "metricsService".