I need to send messages through kafka and found all the examples in "Learn by Example" very helpful. I do need to add headers to the messages I'm sending and I'm not finding examples how to add the headers when producing or read the headers when consuming. Is it possible? any examples anywhere?
Can a producer send headers for a kafka message?
152 Views Asked by aemadrid At
1
There are 1 best solutions below
Related Questions in BALLERINA
- Locally testing OS environmental variables in Ballerina
- In the Ballerina Language how do I hot reload code via `bal run` without a server restart?
- Querying distinct values in Ballerina Query Expressions
- How does the field access behave after cloning a constant map in Ballerina
- Can we ignore case when doing ballerina regexp matches
- Uploading a REST API response to an SFTP server in Ballerina
- Clarification on type inclusions in record in Ballerina
- The assertExactEquals is not working as expected for errors Ballerina testing
- Map the Rest Fields when Data Mapping from One Record to Another in Ballerina
- How to change TLS protocol settings in HttpClient in Ballerina
- Ballerina timing out after 1 minute
- Compilation fails with gmail connector in Ballerina
- Find intersection of 2 arrays in Ballerina
- Error messages does not contain description in native executable in Ballerina
- Error while bal native build for docker using Ballerina
Trending Questions
- UIImageView Frame Doesn't Reflect Constraints
- Is it possible to use adb commands to click on a view by finding its ID?
- How to create a new web character symbol recognizable by html/javascript?
- Why isn't my CSS3 animation smooth in Google Chrome (but very smooth on other browsers)?
- Heap Gives Page Fault
- Connect ffmpeg to Visual Studio 2008
- Both Object- and ValueAnimator jumps when Duration is set above API LvL 24
- How to avoid default initialization of objects in std::vector?
- second argument of the command line arguments in a format other than char** argv or char* argv[]
- How to improve efficiency of algorithm which generates next lexicographic permutation?
- Navigating to the another actvity app getting crash in android
- How to read the particular message format in android and store in sqlite database?
- Resetting inventory status after order is cancelled
- Efficiently compute powers of X in SSE/AVX
- Insert into an external database using ajax and php : POST 500 (Internal Server Error)
Popular # Hahtags
Popular Questions
- How do I undo the most recent local commits in Git?
- How can I remove a specific item from an array in JavaScript?
- How do I delete a Git branch locally and remotely?
- Find all files containing a specific text (string) on Linux?
- How do I revert a Git repository to a previous commit?
- How do I create an HTML button that acts like a link?
- How do I check out a remote Git branch?
- How do I force "git pull" to overwrite local files?
- How do I list all files of a directory?
- How to check whether a string contains a substring in JavaScript?
- How do I redirect to another webpage?
- How can I iterate over rows in a Pandas DataFrame?
- How do I convert a String to an int in Java?
- Does Python have a string 'contains' substring method?
- How do I check if a string contains a specific word?
Currently Ballerina Kafka module does not support adding custom headers. I have created an issue for this feature.
Hopefully this will be supported in a near-future release.