Is your feature request related to a problem? Please describe.
Currently our application only supports Kafka message consumption for event processing. If a job workflow needs to produce a Kafka message to extend communication between services, it is not possible.
Describe the solution you'd like
Integrate a producer object that is configured to a specific Kafka topic. Expose functions that allow users to easily produce messages.
:rocket: Feature Request
Is your feature request related to a problem? Please describe.
Currently our application only supports Kafka message consumption for event processing. If a job workflow needs to produce a Kafka message to extend communication between services, it is not possible.
Describe the solution you'd like
Integrate a producer object that is configured to a specific Kafka topic. Expose functions that allow users to easily produce messages.
Teachability, Documentation, Adoption, Migration Strategy
As a user, I would like to implement producing a message to communicate with other services when an event has been processed by a job.