[FEATURE] Add support for sending additional metadata in the MessagingInterface
#4472
Open
2 tasks done
Labels
A-Analytics
A-framework
Area: Framework
C-feature
Category: Feature request or enhancement
good first issue
Good for newcomers
Feature Description
In the current implementation of message interface I can only send a Message & a timestamp associated with the message,
There is no accomodation to send additional metadata about the message which isn't part of the data but could be propogated to the downstream implementations,
These could be used downstream as kafka headers or redis hashes or partition keys.
Possible Implementation
metadata can be a simplistic
HashMap<String, String>
and can be either accomodated as a new param in theMessagingInterface
or a new method on theMessage
Interface.The implementers of MessageInterface can handle it as follows
Send the metadata as headers
Log the metadata as a separate key along with the raw data
Have you spent some time checking if this feature request has been raised before?
Have you read the Contributing Guidelines?
Are you willing to submit a PR?
None
The text was updated successfully, but these errors were encountered: