Kafka Source: add option to copy Kafka Headers to Pulsar properties

[eolivelli]

Search before asking

• [X] I searched in the issues and found nothing similar.

Motivation

Currently in the Kafka Source we are not copyng the headers but only the payload. I would be great to have all Kafka Headers and maybe some additional metadata, like the original topic, partition, offset....

Solution

Add a flag in the Kafka Source

Alternatives

No response

Anything else?

No response

Are you willing to submit a PR?

• [ ] I'm willing to submit a PR!

[aymkhalil]

I'm working on it.