apache / apache/pulsar-adapters

kafka record headers are not being handled

Open
#45 0 comments 0 reactions 0 assignees View on GitHub
Dominant language
Java
Stars
24
Forks
30
PR merge metrics
No merged PRs in 30d

Description

**Is your enhancement request related to a problem? Please describe.**
Using this as a drop-in replacement for the KafkaProducer & KafkaConsumer coming from native kafka libraries. When the ProducerRecord is having any `Header` entries, they are not being sent to message, causing the consumer not able to access these headers

**Describe the solution you'd like**
Ideally, all the kafka record headers should be passed as-is so that the consumer can access them via KafkaConsumer interface.

**Describe alternatives you've considered**
None

**Additional context**
None

Contributor guide

No contributing guide indexed for this repository

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.