Enriching Kafka Producer Activity with OpenTelemetry addition of custom tags

[davidxavier77]

Currently, our OpenTelemetry activity is created and managed within the consumer context:

Activity is created in the OnConsumeStarted event.
Activity is disposed in the OnConsumeCompleted event.
These events are handled by the OpenTelemetryConsumerEventsHandler class.

Problem:
When we call ProduceAsync on the Kafkaflow producer, the current activity is always null. This means we're unable to add custom tags for our producer operations.

Question:
Is there a way to enrich the internal activity for Kafka producer operations that we might be overlooking? We'd like to capture OpenTelemetry data for producer operations.

Possible areas to explore:

Is there an equivalent event handler for producer operations?
Can we create a custom activity for producer operations?
Is there a way to link consumer and producer activities?
Any insights, suggestions, or examples would be greatly appreciated.